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-04-04T06:00:00+00:00 TriggerDagRunOperator 2021-04-04T07:11:29.573303+00:00 2021-04-04T07:11:29.978133+00:00 0:00:00.404830 13401 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T07:11:27.189853+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-04T06:05:00+00:00 EmrJobFlowSensor 2021-04-04T07:06:06.815384+00:00 2021-04-04T07:15:09.422933+00:00 0:09:02.607549 13400 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T07:06:04.491021+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-04T06:05:00+00:00 EmrCreateJobFlowOperator 2021-04-04T07:05:45.069811+00:00 2021-04-04T07:05:46.721475+00:00 0:00:01.651664 13399 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T07:05:42.552946+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-04T06:05:00+00:00 PythonOperator 2021-04-04T07:05:24.744869+00:00 2021-04-04T07:05:27.547237+00:00 0:00:02.802368 13398 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T07:05:22.457463+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-04T06:00:00+00:00 EmrJobFlowSensor 2021-04-04T07:01:04.353311+00:00 2021-04-04T07:11:07.196185+00:00 0:10:02.842874 13397 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T07:01:01.866757+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-04T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T07:00:42.144008+00:00 2021-04-04T07:00:43.997189+00:00 0:00:01.853181 13396 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-04T07:00:39.850199+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-04T06:00:00+00:00 PythonOperator 2021-04-04T07:00:20.080810+00:00 2021-04-04T07:00:22.803712+00:00 0:00:02.722902 13395 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-04T07:00:17.691064+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-04T05:00:00+00:00 EmrJobFlowSensor 2021-04-04T06:11:25.420345+00:00 2021-04-04T06:20:28.071642+00:00 0:09:02.651297 13393 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T06:11:23.194591+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-04T05:00:00+00:00 EmrJobFlowSensor 2021-04-04T06:11:15.632502+00:00 2021-04-04T06:21:18.370326+00:00 0:10:02.737824 13392 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T06:11:13.262580+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-04T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T06:11:03.487500+00:00 2021-04-04T06:11:05.445760+00:00 0:00:01.958260 13391 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T06:11:01.084799+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-04T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T06:10:55.502466+00:00 2021-04-04T06:10:57.299047+00:00 0:00:01.796581 13390 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T06:10:53.087826+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-04T05:00:00+00:00 PythonOperator 2021-04-04T06:10:41.217894+00:00 2021-04-04T06:10:44.068449+00:00 0:00:02.850555 13389 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T06:10:39.017183+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-04T05:00:00+00:00 PythonOperator 2021-04-04T06:10:33.300375+00:00 2021-04-04T06:10:36.264366+00:00 0:00:02.963991 13388 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T06:10:31.011235+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-04T05:00:00+00:00 TriggerDagRunOperator 2021-04-04T06:10:25.462073+00:00 2021-04-04T06:10:26.014591+00:00 0:00:00.552518 13387 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T06:10:23.006710+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-04T05:00:00+00:00 TriggerDagRunOperator 2021-04-04T06:10:25.349939+00:00 2021-04-04T06:10:25.815898+00:00 0:00:00.465959 13386 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T06:10:23.006672+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-04T05:05:00+00:00 EmrJobFlowSensor 2021-04-04T06:05:50.683530+00:00 2021-04-04T06:14:53.249916+00:00 0:09:02.566386 13385 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T06:05:48.510206+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-04T05:05:00+00:00 EmrCreateJobFlowOperator 2021-04-04T06:05:28.858783+00:00 2021-04-04T06:05:30.604908+00:00 0:00:01.746125 13384 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T06:05:26.472876+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-04T05:05:00+00:00 PythonOperator 2021-04-04T06:05:06.785680+00:00 2021-04-04T06:05:09.506995+00:00 0:00:02.721315 13383 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T06:05:04.446862+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-04T05:00:00+00:00 EmrJobFlowSensor 2021-04-04T06:01:04.668682+00:00 2021-04-04T06:10:07.438137+00:00 0:09:02.769455 13382 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T06:01:02.055853+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-04T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T06:00:42.329187+00:00 2021-04-04T06:00:44.039118+00:00 0:00:01.709931 13381 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-04T06:00:39.996827+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-04T05:00:00+00:00 PythonOperator 2021-04-04T06:00:20.303693+00:00 2021-04-04T06:00:23.016879+00:00 0:00:02.713186 13380 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-04T06:00:17.969704+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-04T04:00:00+00:00 EmrJobFlowSensor 2021-04-04T05:12:36.305146+00:00 2021-04-04T05:22:39.087470+00:00 0:10:02.782324 13378 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T05:12:34.121883+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-04T04:00:00+00:00 EmrJobFlowSensor 2021-04-04T05:12:24.410182+00:00 2021-04-04T05:22:27.221137+00:00 0:10:02.810955 13377 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T05:12:22.119385+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-04T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T05:12:14.596335+00:00 2021-04-04T05:12:16.368071+00:00 0:00:01.771736 13376 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T05:12:12.105609+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-04T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T05:12:04.572694+00:00 2021-04-04T05:12:06.333176+00:00 0:00:01.760482 13375 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T05:12:02.096563+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-04T04:00:00+00:00 PythonOperator 2021-04-04T05:11:54.755105+00:00 2021-04-04T05:11:57.535896+00:00 0:00:02.780791 13374 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T05:11:52.088088+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-04T04:00:00+00:00 PythonOperator 2021-04-04T05:11:42.599523+00:00 2021-04-04T05:11:45.570911+00:00 0:00:02.971388 13373 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T05:11:40.071403+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-04T04:00:00+00:00 TriggerDagRunOperator 2021-04-04T05:11:30.872977+00:00 2021-04-04T05:11:31.383188+00:00 0:00:00.510211 13372 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T05:11:28.241121+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-04T04:00:00+00:00 TriggerDagRunOperator 2021-04-04T05:11:30.807664+00:00 2021-04-04T05:11:31.231563+00:00 0:00:00.423899 13371 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T05:11:28.241064+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-04T04:05:00+00:00 EmrJobFlowSensor 2021-04-04T05:06:07.757521+00:00 2021-04-04T05:15:10.334038+00:00 0:09:02.576517 13370 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T05:06:05.551897+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-04T04:05:00+00:00 EmrCreateJobFlowOperator 2021-04-04T05:05:45.873297+00:00 2021-04-04T05:05:47.651496+00:00 0:00:01.778199 13369 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T05:05:43.384012+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-04T04:05:00+00:00 PythonOperator 2021-04-04T05:05:25.654300+00:00 2021-04-04T05:05:28.333176+00:00 0:00:02.678876 13368 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T05:05:23.368669+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-04T04:00:00+00:00 EmrJobFlowSensor 2021-04-04T05:01:03.165430+00:00 2021-04-04T05:11:06.061450+00:00 0:10:02.896020 13367 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T05:01:00.841327+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-04T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T05:00:43.073002+00:00 2021-04-04T05:00:44.923730+00:00 0:00:01.850728 13366 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-04T05:00:40.823300+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-04T04:00:00+00:00 PythonOperator 2021-04-04T05:00:21.146359+00:00 2021-04-04T05:00:24.037451+00:00 0:00:02.891092 13365 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-04T05:00:18.802072+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-04T03:00:00+00:00 EmrJobFlowSensor 2021-04-04T04:12:45.259448+00:00 2021-04-04T04:22:48.099187+00:00 0:10:02.839739 13363 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T04:12:42.770347+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-04T03:00:00+00:00 EmrJobFlowSensor 2021-04-04T04:12:33.284335+00:00 2021-04-04T04:21:35.955240+00:00 0:09:02.670905 13362 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T04:12:30.757696+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-04T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T04:12:24.925881+00:00 2021-04-04T04:12:26.600729+00:00 0:00:01.674848 13361 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T04:12:22.704271+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-04T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T04:12:10.921882+00:00 2021-04-04T04:12:12.748872+00:00 0:00:01.826990 13360 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T04:12:08.693538+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-04T03:00:00+00:00 PythonOperator 2021-04-04T04:12:02.942563+00:00 2021-04-04T04:12:05.680237+00:00 0:00:02.737674 13359 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T04:12:00.683916+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-04T03:00:00+00:00 PythonOperator 2021-04-04T04:11:48.916673+00:00 2021-04-04T04:11:51.941427+00:00 0:00:03.024754 13358 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T04:11:46.626412+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-04T03:00:00+00:00 TriggerDagRunOperator 2021-04-04T04:11:42.931230+00:00 2021-04-04T04:11:43.340714+00:00 0:00:00.409484 13357 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T04:11:40.623316+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-04T03:00:00+00:00 TriggerDagRunOperator 2021-04-04T04:11:42.959065+00:00 2021-04-04T04:11:43.497781+00:00 0:00:00.538716 13356 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T04:11:40.623282+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-04T03:05:00+00:00 EmrJobFlowSensor 2021-04-04T04:05:54.428914+00:00 2021-04-04T04:14:56.960513+00:00 0:09:02.531599 13355 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T04:05:52.226043+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-04T03:05:00+00:00 EmrCreateJobFlowOperator 2021-04-04T04:05:34.408639+00:00 2021-04-04T04:05:36.039012+00:00 0:00:01.630373 13354 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T04:05:32.213488+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-04T03:05:00+00:00 PythonOperator 2021-04-04T04:05:10.570984+00:00 2021-04-04T04:05:13.239931+00:00 0:00:02.668947 13353 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T04:05:08.258451+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-04T03:00:00+00:00 EmrJobFlowSensor 2021-04-04T04:01:17.908812+00:00 2021-04-04T04:11:20.619843+00:00 0:10:02.711031 13352 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T04:01:15.775338+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-04T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T04:00:56.088043+00:00 2021-04-04T04:00:57.792283+00:00 0:00:01.704240 13351 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-04T04:00:53.756544+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-04T03:00:00+00:00 PythonOperator 2021-04-04T04:00:26.331926+00:00 2021-04-04T04:00:29.035471+00:00 0:00:02.703545 13350 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-04T04:00:23.749637+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-04T02:00:00+00:00 EmrJobFlowSensor 2021-04-04T03:11:25.088879+00:00 2021-04-04T03:21:27.835485+00:00 0:10:02.746606 13348 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T03:11:22.561810+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-04T02:00:00+00:00 EmrJobFlowSensor 2021-04-04T03:11:18.998463+00:00 2021-04-04T03:20:21.531622+00:00 0:09:02.533159 13347 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T03:11:16.476441+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-04T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T03:11:04.653386+00:00 2021-04-04T03:11:06.420585+00:00 0:00:01.767199 13346 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T03:11:02.422028+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-04T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T03:10:58.618334+00:00 2021-04-04T03:11:00.324626+00:00 0:00:01.706292 13345 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T03:10:56.424802+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-04T02:00:00+00:00 PythonOperator 2021-04-04T03:10:42.553451+00:00 2021-04-04T03:10:45.239951+00:00 0:00:02.686500 13344 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T03:10:40.400762+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-04T02:00:00+00:00 PythonOperator 2021-04-04T03:10:36.699926+00:00 2021-04-04T03:10:39.779814+00:00 0:00:03.079888 13343 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T03:10:34.397547+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-04T02:00:00+00:00 TriggerDagRunOperator 2021-04-04T03:10:19.403455+00:00 2021-04-04T03:10:19.930764+00:00 0:00:00.527309 13342 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T03:10:16.389347+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-04T02:00:00+00:00 TriggerDagRunOperator 2021-04-04T03:10:18.752011+00:00 2021-04-04T03:10:19.145163+00:00 0:00:00.393152 13341 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T03:10:16.389301+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-04T02:05:00+00:00 EmrJobFlowSensor 2021-04-04T03:05:48.275819+00:00 2021-04-04T03:14:50.870977+00:00 0:09:02.595158 13340 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T03:05:45.753283+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-04T02:05:00+00:00 EmrCreateJobFlowOperator 2021-04-04T03:05:25.965883+00:00 2021-04-04T03:05:27.713359+00:00 0:00:01.747476 13339 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T03:05:23.760436+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-04T02:05:00+00:00 PythonOperator 2021-04-04T03:05:06.071379+00:00 2021-04-04T03:05:08.852737+00:00 0:00:02.781358 13338 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T03:05:03.648540+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-04T02:00:00+00:00 EmrJobFlowSensor 2021-04-04T03:01:03.812856+00:00 2021-04-04T03:10:06.654895+00:00 0:09:02.842039 13337 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T03:01:01.185782+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-04T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T03:00:41.212827+00:00 2021-04-04T03:00:42.899247+00:00 0:00:01.686420 13336 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-04T03:00:39.083173+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-04T02:00:00+00:00 PythonOperator 2021-04-04T03:00:21.352793+00:00 2021-04-04T03:00:24.107913+00:00 0:00:02.755120 13335 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-04T03:00:19.064324+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-04T01:00:00+00:00 EmrJobFlowSensor 2021-04-04T02:12:07.461412+00:00 2021-04-04T02:21:10.101225+00:00 0:09:02.639813 13333 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T02:12:05.191700+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-04T01:00:00+00:00 EmrJobFlowSensor 2021-04-04T02:11:47.690947+00:00 2021-04-04T02:21:50.605077+00:00 0:10:02.914130 13332 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T02:11:45.189616+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-04T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T02:11:43.617811+00:00 2021-04-04T02:11:45.317224+00:00 0:00:01.699413 13331 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T02:11:41.177127+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-04T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T02:11:27.913932+00:00 2021-04-04T02:11:29.608619+00:00 0:00:01.694687 13330 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T02:11:25.171129+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-04T01:00:00+00:00 PythonOperator 2021-04-04T02:11:23.314774+00:00 2021-04-04T02:11:26.707246+00:00 0:00:03.392472 13329 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T02:11:21.100804+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-04T01:00:00+00:00 PythonOperator 2021-04-04T02:11:05.417255+00:00 2021-04-04T02:11:08.294881+00:00 0:00:02.877626 13328 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T02:11:03.090201+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-04T01:00:00+00:00 TriggerDagRunOperator 2021-04-04T02:11:00.035903+00:00 2021-04-04T02:11:00.569718+00:00 0:00:00.533815 13327 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T02:10:57.101454+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-04T01:00:00+00:00 TriggerDagRunOperator 2021-04-04T02:10:59.386851+00:00 2021-04-04T02:10:59.776462+00:00 0:00:00.389611 13326 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T02:10:57.101489+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-04T01:05:00+00:00 EmrJobFlowSensor 2021-04-04T02:06:04.660232+00:00 2021-04-04T02:14:07.142520+00:00 0:08:02.482288 13325 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T02:06:02.500235+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-04T01:05:00+00:00 EmrCreateJobFlowOperator 2021-04-04T02:05:42.847669+00:00 2021-04-04T02:05:44.591052+00:00 0:00:01.743383 13324 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T02:05:40.475980+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-04T01:05:00+00:00 PythonOperator 2021-04-04T02:05:12.597564+00:00 2021-04-04T02:05:15.272964+00:00 0:00:02.675400 13323 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T02:05:10.440025+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-04T01:00:00+00:00 EmrJobFlowSensor 2021-04-04T02:00:50.663076+00:00 2021-04-04T02:10:53.588493+00:00 0:10:02.925417 13322 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T02:00:48.157711+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-04T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T02:00:28.288037+00:00 2021-04-04T02:00:30.013492+00:00 0:00:01.725455 13321 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-04T02:00:26.061341+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-04T01:00:00+00:00 PythonOperator 2021-04-04T02:00:08.429844+00:00 2021-04-04T02:00:11.224463+00:00 0:00:02.794619 13320 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-04T02:00:06.044387+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-04T00:00:00+00:00 EmrJobFlowSensor 2021-04-04T01:12:41.746374+00:00 2021-04-04T01:21:44.474093+00:00 0:09:02.727719 13318 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T01:12:39.348708+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-04T00:00:00+00:00 EmrJobFlowSensor 2021-04-04T01:12:39.736538+00:00 2021-04-04T01:24:42.738101+00:00 0:12:03.001563 13317 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T01:12:37.352672+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-04T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T01:12:21.421373+00:00 2021-04-04T01:12:23.140912+00:00 0:00:01.719539 13316 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T01:12:19.254480+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-04T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T01:12:17.429126+00:00 2021-04-04T01:12:19.178378+00:00 0:00:01.749252 13315 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T01:12:15.250573+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-04T00:00:00+00:00 PythonOperator 2021-04-04T01:11:59.874135+00:00 2021-04-04T01:12:02.598629+00:00 0:00:02.724494 13314 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T01:11:57.233494+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-04T00:00:00+00:00 PythonOperator 2021-04-04T01:11:57.565405+00:00 2021-04-04T01:12:00.820841+00:00 0:00:03.255436 13313 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T01:11:55.232404+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-04T00:00:00+00:00 TriggerDagRunOperator 2021-04-04T01:11:37.866582+00:00 2021-04-04T01:11:38.474602+00:00 0:00:00.608020 13312 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T01:11:35.278439+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-04T00:00:00+00:00 TriggerDagRunOperator 2021-04-04T01:11:37.689484+00:00 2021-04-04T01:11:38.092538+00:00 0:00:00.403054 13311 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T01:11:35.278390+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-04T00:05:00+00:00 EmrJobFlowSensor 2021-04-04T01:05:52.882816+00:00 2021-04-04T01:14:55.287903+00:00 0:09:02.405087 13310 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T01:05:50.603975+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-04T00:05:00+00:00 EmrCreateJobFlowOperator 2021-04-04T01:05:31.215164+00:00 2021-04-04T01:05:32.944289+00:00 0:00:01.729125 13309 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T01:05:28.463849+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-04T00:05:00+00:00 PythonOperator 2021-04-04T01:05:10.630151+00:00 2021-04-04T01:05:13.282572+00:00 0:00:02.652421 13308 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T01:05:08.307739+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-04T00:00:00+00:00 EmrJobFlowSensor 2021-04-04T01:01:10.214990+00:00 2021-04-04T01:11:13.112473+00:00 0:10:02.897483 13307 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T01:01:07.843602+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-04T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T01:00:48.150022+00:00 2021-04-04T01:00:49.834454+00:00 0:00:01.684432 13306 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-04T01:00:45.821714+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-04T00:00:00+00:00 PythonOperator 2021-04-04T01:00:16.078641+00:00 2021-04-04T01:00:18.786758+00:00 0:00:02.708117 13305 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-04T01:00:13.794797+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-03T23:00:00+00:00 EmrJobFlowSensor 2021-04-04T00:12:22.427886+00:00 2021-04-04T00:22:25.226022+00:00 0:10:02.798136 13303 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T00:12:20.300849+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-03T23:00:00+00:00 EmrJobFlowSensor 2021-04-04T00:12:02.559811+00:00 2021-04-04T00:20:05.188278+00:00 0:08:02.628467 13302 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T00:12:00.283092+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-03T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T00:12:00.687681+00:00 2021-04-04T00:12:02.492047+00:00 0:00:01.804366 13301 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T00:11:58.354479+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-03T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T00:11:38.682278+00:00 2021-04-04T00:11:40.393922+00:00 0:00:01.711644 13300 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T00:11:36.255581+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-03T23:00:00+00:00 PythonOperator 2021-04-04T00:11:32.554889+00:00 2021-04-04T00:11:35.514770+00:00 0:00:02.959881 13299 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T00:11:30.257451+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-03T23:00:00+00:00 PythonOperator 2021-04-04T00:11:16.510480+00:00 2021-04-04T00:11:19.349691+00:00 0:00:02.839211 13298 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T00:11:14.235384+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-03T23:00:00+00:00 TriggerDagRunOperator 2021-04-04T00:11:08.587733+00:00 2021-04-04T00:11:09.147866+00:00 0:00:00.560133 13297 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T00:11:06.231875+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-03T23:00:00+00:00 TriggerDagRunOperator 2021-04-04T00:11:08.552405+00:00 2021-04-04T00:11:09.007849+00:00 0:00:00.455444 13296 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T00:11:06.231841+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-03T23:05:00+00:00 EmrJobFlowSensor 2021-04-04T00:05:56.073074+00:00 2021-04-04T00:14:58.609729+00:00 0:09:02.536655 13295 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T00:05:53.846237+00:00 2 default_pool