Task Instances

  State Dag Id Task Id Execution Date Operator Start Date End Date Duration Job Id Hostname Unixname Priority Weight Queue Queued Dttm Try Number Pool Log Url
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-07T15:00:00+00:00 TriggerDagRunOperator 2021-05-07T16:11:17.075270+00:00 2021-05-07T16:11:17.511559+00:00 0:00:00.436289 25515 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T16:11:14.521879+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-07T15:00:00+00:00 TriggerDagRunOperator 2021-05-07T16:11:16.809940+00:00 2021-05-07T16:11:17.407380+00:00 0:00:00.597440 25514 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T16:11:14.521909+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-07T15:05:00+00:00 EmrJobFlowSensor 2021-05-07T16:06:00.081324+00:00 2021-05-07T16:15:02.671540+00:00 0:09:02.590216 25513 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T16:05:57.868490+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-07T15:05:00+00:00 EmrCreateJobFlowOperator 2021-05-07T16:05:38.394106+00:00 2021-05-07T16:05:40.087250+00:00 0:00:01.693144 25512 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-07T16:05:35.844699+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-07T15:05:00+00:00 PythonOperator 2021-05-07T16:05:14.127280+00:00 2021-05-07T16:05:17.229786+00:00 0:00:03.102506 25511 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T16:05:11.855754+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-07T15:00:00+00:00 EmrJobFlowSensor 2021-05-07T16:01:05.513358+00:00 2021-05-07T16:11:08.230993+00:00 0:10:02.717635 25510 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T16:01:03.190579+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-07T15:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T16:00:43.388064+00:00 2021-05-07T16:00:45.108903+00:00 0:00:01.720839 25509 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-07T16:00:41.110640+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-07T15:00:00+00:00 PythonOperator 2021-05-07T16:00:21.437088+00:00 2021-05-07T16:00:24.518393+00:00 0:00:03.081305 25508 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-07T16:00:19.094566+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-07T14:00:00+00:00 EmrJobFlowSensor 2021-05-07T15:11:18.676058+00:00 2021-05-07T15:20:21.321525+00:00 0:09:02.645467 25506 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T15:11:16.577618+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-07T14:00:00+00:00 EmrJobFlowSensor 2021-05-07T15:11:10.744486+00:00 2021-05-07T15:21:13.802909+00:00 0:10:03.058423 25505 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T15:11:08.527910+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-07T14:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T15:10:59.225709+00:00 2021-05-07T15:11:00.892189+00:00 0:00:01.666480 25504 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-07T15:10:56.578775+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-07T14:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T15:10:50.777618+00:00 2021-05-07T15:10:52.490857+00:00 0:00:01.713239 25503 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-07T15:10:48.569903+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-07T14:00:00+00:00 PythonOperator 2021-05-07T15:10:36.719463+00:00 2021-05-07T15:10:39.787673+00:00 0:00:03.068210 25502 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T15:10:34.491424+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-07T14:00:00+00:00 PythonOperator 2021-05-07T15:10:28.725466+00:00 2021-05-07T15:10:32.116594+00:00 0:00:03.391128 25501 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T15:10:26.431158+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-07T14:00:00+00:00 TriggerDagRunOperator 2021-05-07T15:10:12.621454+00:00 2021-05-07T15:10:13.155938+00:00 0:00:00.534484 25500 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T15:10:10.412863+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-07T14:00:00+00:00 TriggerDagRunOperator 2021-05-07T15:10:12.546836+00:00 2021-05-07T15:10:12.930409+00:00 0:00:00.383573 25499 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T15:10:10.412898+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-07T14:05:00+00:00 EmrJobFlowSensor 2021-05-07T15:05:53.803989+00:00 2021-05-07T15:14:56.290843+00:00 0:09:02.486854 25498 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T15:05:51.734648+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-07T14:05:00+00:00 EmrCreateJobFlowOperator 2021-05-07T15:05:32.330244+00:00 2021-05-07T15:05:34.004886+00:00 0:00:01.674642 25497 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-07T15:05:29.851066+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-07T14:05:00+00:00 PythonOperator 2021-05-07T15:05:10.037000+00:00 2021-05-07T15:05:13.124230+00:00 0:00:03.087230 25496 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T15:05:07.744165+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-07T14:00:00+00:00 EmrJobFlowSensor 2021-05-07T15:00:55.356176+00:00 2021-05-07T15:09:58.077101+00:00 0:09:02.720925 25495 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T15:00:53.079249+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-07T14:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T15:00:33.274488+00:00 2021-05-07T15:00:35.007276+00:00 0:00:01.732788 25494 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-07T15:00:31.065356+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-07T14:00:00+00:00 PythonOperator 2021-05-07T15:00:11.226985+00:00 2021-05-07T15:00:14.328318+00:00 0:00:03.101333 25493 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-07T15:00:08.989514+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-07T13:00:00+00:00 EmrJobFlowSensor 2021-05-07T14:12:19.228096+00:00 2021-05-07T14:23:22.259123+00:00 0:11:03.031027 25491 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T14:12:16.407037+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-07T13:00:00+00:00 EmrJobFlowSensor 2021-05-07T14:12:17.012136+00:00 2021-05-07T14:22:20.183255+00:00 0:10:03.171119 25490 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T14:12:14.350051+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-07T13:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T14:11:57.131999+00:00 2021-05-07T14:11:58.811767+00:00 0:00:01.679768 25489 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-07T14:11:54.348408+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-07T13:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T14:11:54.845730+00:00 2021-05-07T14:11:56.847201+00:00 0:00:02.001471 25488 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-07T14:11:52.360390+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-07T13:00:00+00:00 PythonOperator 2021-05-07T14:11:34.611831+00:00 2021-05-07T14:11:37.961388+00:00 0:00:03.349557 25487 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T14:11:32.274413+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-07T13:00:00+00:00 PythonOperator 2021-05-07T14:11:32.873359+00:00 2021-05-07T14:11:35.936855+00:00 0:00:03.063496 25486 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T14:11:30.370521+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-07T13:00:00+00:00 TriggerDagRunOperator 2021-05-07T14:11:16.520535+00:00 2021-05-07T14:11:17.058794+00:00 0:00:00.538259 25485 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T14:11:14.198592+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-07T13:00:00+00:00 TriggerDagRunOperator 2021-05-07T14:11:16.287212+00:00 2021-05-07T14:11:16.729514+00:00 0:00:00.442302 25484 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T14:11:14.198561+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-07T13:05:00+00:00 EmrJobFlowSensor 2021-05-07T14:05:49.839322+00:00 2021-05-07T14:14:52.532068+00:00 0:09:02.692746 25483 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T14:05:47.618056+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-07T13:05:00+00:00 EmrCreateJobFlowOperator 2021-05-07T14:05:28.091609+00:00 2021-05-07T14:05:29.897735+00:00 0:00:01.806126 25482 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-07T14:05:25.662374+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-07T13:05:00+00:00 PythonOperator 2021-05-07T14:05:05.705144+00:00 2021-05-07T14:05:08.799555+00:00 0:00:03.094411 25481 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T14:05:03.515064+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-07T13:00:00+00:00 EmrJobFlowSensor 2021-05-07T14:00:59.106288+00:00 2021-05-07T14:11:01.951578+00:00 0:10:02.845290 25480 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T14:00:56.924564+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-07T13:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T14:00:39.512249+00:00 2021-05-07T14:00:41.306511+00:00 0:00:01.794262 25479 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-07T14:00:36.947588+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-07T13:00:00+00:00 PythonOperator 2021-05-07T14:00:17.057836+00:00 2021-05-07T14:00:20.095120+00:00 0:00:03.037284 25478 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-07T14:00:14.835557+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-07T12:00:00+00:00 EmrJobFlowSensor 2021-05-07T13:17:11.477650+00:00 2021-05-07T13:27:14.408699+00:00 0:10:02.931049 25477 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T13:17:09.241168+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-07T12:00:00+00:00 EmrJobFlowSensor 2021-05-07T13:16:58.083567+00:00 2021-05-07T13:26:00.725414+00:00 0:09:02.641847 25476 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T13:16:55.344176+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-07T12:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T13:16:49.495907+00:00 2021-05-07T13:16:51.261189+00:00 0:00:01.765282 25475 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-07T13:16:47.212567+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-07T12:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T13:16:35.821093+00:00 2021-05-07T13:16:37.687001+00:00 0:00:01.865908 25474 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-07T13:16:33.253500+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-07T12:00:00+00:00 PythonOperator 2021-05-07T13:16:27.336172+00:00 2021-05-07T13:16:30.580718+00:00 0:00:03.244546 25473 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T13:16:25.183207+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-07T12:00:00+00:00 PythonOperator 2021-05-07T13:16:15.464036+00:00 2021-05-07T13:16:18.617807+00:00 0:00:03.153771 25472 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T13:16:13.185658+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-07T12:00:00+00:00 TriggerDagRunOperator 2021-05-07T13:16:05.682449+00:00 2021-05-07T13:16:06.226402+00:00 0:00:00.543953 25471 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T13:16:03.114488+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-07T12:00:00+00:00 TriggerDagRunOperator 2021-05-07T13:16:05.592985+00:00 2021-05-07T13:16:05.977326+00:00 0:00:00.384341 25470 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T13:16:03.114517+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-07T12:05:00+00:00 EmrJobFlowSensor 2021-05-07T13:06:11.642853+00:00 2021-05-07T13:15:14.221606+00:00 0:09:02.578753 25468 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T13:06:09.481770+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-07T12:05:00+00:00 EmrCreateJobFlowOperator 2021-05-07T13:05:51.681049+00:00 2021-05-07T13:05:53.322330+00:00 0:00:01.641281 25467 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-07T13:05:49.468608+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-07T12:05:00+00:00 PythonOperator 2021-05-07T13:05:19.828000+00:00 2021-05-07T13:05:22.864610+00:00 0:00:03.036610 25466 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T13:05:17.465279+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-07T12:00:00+00:00 EmrJobFlowSensor 2021-05-07T13:01:07.112993+00:00 2021-05-07T13:10:09.801292+00:00 0:09:02.688299 25465 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T13:01:04.992653+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-07T12:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T13:00:45.244109+00:00 2021-05-07T13:00:46.920713+00:00 0:00:01.676604 25464 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-07T13:00:42.960704+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-07T12:00:00+00:00 PythonOperator 2021-05-07T13:00:25.182062+00:00 2021-05-07T13:00:28.348693+00:00 0:00:03.166631 25463 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-07T13:00:22.838512+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-07T11:00:00+00:00 EmrJobFlowSensor 2021-05-07T12:11:09.367666+00:00 2021-05-07T12:20:12.091257+00:00 0:09:02.723591 25462 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T12:11:06.853406+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-07T11:00:00+00:00 EmrJobFlowSensor 2021-05-07T12:11:05.088885+00:00 2021-05-07T12:23:08.119728+00:00 0:12:03.030843 25461 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T12:11:02.856361+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-07T11:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T12:10:47.290152+00:00 2021-05-07T12:10:49.092829+00:00 0:00:01.802677 25460 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-07T12:10:44.771784+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-07T11:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T12:10:40.972682+00:00 2021-05-07T12:10:42.784027+00:00 0:00:01.811345 25459 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-07T12:10:38.704330+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-07T11:00:00+00:00 PythonOperator 2021-05-07T12:10:25.567109+00:00 2021-05-07T12:10:28.758209+00:00 0:00:03.191100 25458 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T12:10:22.686581+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-07T11:05:00+00:00 EmrJobFlowSensor 2021-05-07T12:10:22.880036+00:00 2021-05-07T12:19:25.584528+00:00 0:09:02.704492 25457 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T12:10:20.693952+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-07T11:00:00+00:00 PythonOperator 2021-05-07T12:10:20.788412+00:00 2021-05-07T12:10:24.757200+00:00 0:00:03.968788 25456 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T12:10:18.689186+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-07T11:05:00+00:00 EmrCreateJobFlowOperator 2021-05-07T12:10:03.599899+00:00 2021-05-07T12:10:05.283237+00:00 0:00:01.683338 25455 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-07T12:10:00.597115+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-07T11:00:00+00:00 TriggerDagRunOperator 2021-05-07T12:10:01.697476+00:00 2021-05-07T12:10:02.393593+00:00 0:00:00.696117 25454 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T12:09:58.549067+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-07T11:00:00+00:00 TriggerDagRunOperator 2021-05-07T12:10:01.293524+00:00 2021-05-07T12:10:01.835471+00:00 0:00:00.541947 25453 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T12:09:58.549096+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-07T11:05:00+00:00 PythonOperator 2021-05-07T12:05:07.496292+00:00 2021-05-07T12:05:10.524132+00:00 0:00:03.027840 25451 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T12:05:05.073639+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-07T11:00:00+00:00 EmrJobFlowSensor 2021-05-07T12:00:48.922272+00:00 2021-05-07T12:09:51.694613+00:00 0:09:02.772341 25450 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T12:00:46.441169+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-07T11:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T12:00:26.704991+00:00 2021-05-07T12:00:28.415323+00:00 0:00:01.710332 25449 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-07T12:00:24.367081+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-07T11:00:00+00:00 PythonOperator 2021-05-07T12:00:06.494595+00:00 2021-05-07T12:00:09.536376+00:00 0:00:03.041781 25448 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-07T12:00:04.269880+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-07T10:00:00+00:00 EmrJobFlowSensor 2021-05-07T11:11:26.156883+00:00 2021-05-07T11:22:29.215907+00:00 0:11:03.059024 25447 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T11:11:24.029700+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-07T10:00:00+00:00 EmrJobFlowSensor 2021-05-07T11:11:20.176045+00:00 2021-05-07T11:20:22.764731+00:00 0:09:02.588686 25446 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T11:11:18.020359+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-07T10:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T11:11:04.853673+00:00 2021-05-07T11:11:06.711806+00:00 0:00:01.858133 25445 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-07T11:11:02.141257+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-07T10:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T11:10:58.598184+00:00 2021-05-07T11:11:00.376483+00:00 0:00:01.778299 25444 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-07T11:10:56.058394+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-07T10:00:00+00:00 PythonOperator 2021-05-07T11:10:42.300924+00:00 2021-05-07T11:10:45.586429+00:00 0:00:03.285505 25443 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T11:10:40.048822+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-07T10:00:00+00:00 PythonOperator 2021-05-07T11:10:38.477628+00:00 2021-05-07T11:10:41.575148+00:00 0:00:03.097520 25442 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T11:10:36.054473+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-07T10:00:00+00:00 TriggerDagRunOperator 2021-05-07T11:10:28.644095+00:00 2021-05-07T11:10:29.162504+00:00 0:00:00.518409 25441 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T11:10:25.983099+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-07T10:00:00+00:00 TriggerDagRunOperator 2021-05-07T11:10:28.517944+00:00 2021-05-07T11:10:28.947245+00:00 0:00:00.429301 25440 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T11:10:25.983054+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-07T10:05:00+00:00 EmrJobFlowSensor 2021-05-07T11:06:11.582063+00:00 2021-05-07T11:15:14.093547+00:00 0:09:02.511484 25439 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T11:06:09.493904+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-07T10:05:00+00:00 EmrCreateJobFlowOperator 2021-05-07T11:05:51.466338+00:00 2021-05-07T11:05:53.106600+00:00 0:00:01.640262 25438 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-07T11:05:49.419552+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-07T10:05:00+00:00 PythonOperator 2021-05-07T11:05:29.706169+00:00 2021-05-07T11:05:32.714313+00:00 0:00:03.008144 25437 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T11:05:27.403114+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-07T10:00:00+00:00 EmrJobFlowSensor 2021-05-07T11:01:00.919214+00:00 2021-05-07T11:10:03.557596+00:00 0:09:02.638382 25435 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T11:00:58.672152+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-07T10:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T11:00:38.936129+00:00 2021-05-07T11:00:40.745582+00:00 0:00:01.809453 25434 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-07T11:00:36.426939+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-07T10:00:00+00:00 PythonOperator 2021-05-07T11:00:17.246162+00:00 2021-05-07T11:00:20.341540+00:00 0:00:03.095378 25433 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-07T11:00:14.454274+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-07T09:00:00+00:00 EmrJobFlowSensor 2021-05-07T10:16:22.455222+00:00 2021-05-07T10:27:25.331629+00:00 0:11:02.876407 25432 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T10:16:20.322747+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-07T09:00:00+00:00 EmrJobFlowSensor 2021-05-07T10:15:58.516000+00:00 2021-05-07T10:25:01.310029+00:00 0:09:02.794029 25431 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T10:15:56.308748+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-07T09:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T10:15:52.696519+00:00 2021-05-07T10:15:54.398863+00:00 0:00:01.702344 25430 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-07T10:15:50.388719+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-07T09:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T10:15:36.647615+00:00 2021-05-07T10:15:38.376135+00:00 0:00:01.728520 25429 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-07T10:15:34.355247+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-07T09:00:00+00:00 PythonOperator 2021-05-07T10:15:30.751396+00:00 2021-05-07T10:15:34.054976+00:00 0:00:03.303580 25428 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T10:15:28.259126+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-07T09:00:00+00:00 PythonOperator 2021-05-07T10:15:06.266865+00:00 2021-05-07T10:15:09.370394+00:00 0:00:03.103529 25427 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T10:15:04.131350+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-07T09:00:00+00:00 TriggerDagRunOperator 2021-05-07T10:14:52.773873+00:00 2021-05-07T10:14:53.398401+00:00 0:00:00.624528 25426 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T10:14:50.124639+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-07T09:00:00+00:00 TriggerDagRunOperator 2021-05-07T10:14:52.474637+00:00 2021-05-07T10:14:52.911466+00:00 0:00:00.436829 25425 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T10:14:50.124680+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-07T09:05:00+00:00 EmrJobFlowSensor 2021-05-07T10:05:47.617430+00:00 2021-05-07T10:14:50.218246+00:00 0:09:02.600816 25424 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T10:05:45.370483+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-07T09:05:00+00:00 EmrCreateJobFlowOperator 2021-05-07T10:05:25.858871+00:00 2021-05-07T10:05:27.682891+00:00 0:00:01.824020 25423 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-07T10:05:23.306256+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-07T09:05:00+00:00 PythonOperator 2021-05-07T10:05:04.009777+00:00 2021-05-07T10:05:07.069076+00:00 0:00:03.059299 25422 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T10:05:01.359620+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-07T09:00:00+00:00 EmrJobFlowSensor 2021-05-07T10:04:31.334293+00:00 2021-05-07T10:14:34.159057+00:00 0:10:02.824764 25421 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T10:04:29.215066+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-07T09:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T10:04:09.612964+00:00 2021-05-07T10:04:11.330793+00:00 0:00:01.717829 25420 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-07T10:04:07.217380+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-07T09:00:00+00:00 PythonOperator 2021-05-07T10:00:19.338415+00:00 2021-05-07T10:00:22.382858+00:00 0:00:03.044443 25418 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-07T10:00:17.047320+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-07T08:00:00+00:00 EmrJobFlowSensor 2021-05-07T09:11:37.317761+00:00 2021-05-07T09:20:39.954559+00:00 0:09:02.636798 25417 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T09:11:34.977153+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-07T08:00:00+00:00 EmrJobFlowSensor 2021-05-07T09:11:29.193693+00:00 2021-05-07T09:23:32.251953+00:00 0:12:03.058260 25416 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T09:11:26.914078+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-07T08:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T09:11:15.721976+00:00 2021-05-07T09:11:17.424178+00:00 0:00:01.702202 25415 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-07T09:11:12.895164+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-07T08:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T09:11:06.978859+00:00 2021-05-07T09:11:08.670750+00:00 0:00:01.691891 25414 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-07T09:11:04.884378+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-07T08:00:00+00:00 PythonOperator 2021-05-07T09:10:53.357423+00:00 2021-05-07T09:10:56.464947+00:00 0:00:03.107524 25413 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T09:10:50.781520+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-07T08:00:00+00:00 PythonOperator 2021-05-07T09:10:45.247485+00:00 2021-05-07T09:10:48.564510+00:00 0:00:03.317025 25412 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T09:10:42.748824+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-07T08:00:00+00:00 TriggerDagRunOperator 2021-05-07T09:10:33.422382+00:00 2021-05-07T09:10:33.953384+00:00 0:00:00.531002 25411 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T09:10:30.706445+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-07T08:00:00+00:00 TriggerDagRunOperator 2021-05-07T09:10:33.165323+00:00 2021-05-07T09:10:33.598268+00:00 0:00:00.432945 25410 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T09:10:30.706399+00:00 2 default_pool