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 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
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-03T23:05:00+00:00 EmrCreateJobFlowOperator 2021-04-04T00:05:36.041697+00:00 2021-04-04T00:05:37.680845+00:00 0:00:01.639148 13294 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T00:05:33.833861+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-03T23:05:00+00:00 PythonOperator 2021-04-04T00:05:12.185038+00:00 2021-04-04T00:05:14.995832+00:00 0:00:02.810794 13293 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T00:05:09.864175+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-03T23:00:00+00:00 EmrJobFlowSensor 2021-04-04T00:00:51.666535+00:00 2021-04-04T00:10:54.650394+00:00 0:10:02.983859 13292 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T00:00:49.325077+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-03T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T00:00:32.023269+00:00 2021-04-04T00:00:33.738175+00:00 0:00:01.714906 13291 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-04T00:00:29.468143+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-03T23:00:00+00:00 PythonOperator 2021-04-04T00:00:09.646081+00:00 2021-04-04T00:00:12.474727+00:00 0:00:02.828646 13290 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-04T00:00:07.290141+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-03T22:00:00+00:00 EmrJobFlowSensor 2021-04-03T23:24:13.231780+00:00 2021-04-03T23:24:14.721450+00:00 0:00:01.489670 13288 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T23:24:10.876204+00:00 3 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-03T22:00:00+00:00 EmrJobFlowSensor 2021-04-03T23:24:07.099662+00:00 2021-04-03T23:24:08.590069+00:00 0:00:01.490407 13287 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T23:24:04.870930+00:00 3 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-03T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T23:11:01.744987+00:00 2021-04-03T23:11:03.656666+00:00 0:00:01.911679 13284 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T23:10:59.433276+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-03T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T23:10:55.761759+00:00 2021-04-03T23:10:57.562924+00:00 0:00:01.801165 13283 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T23:10:53.426177+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-03T22:00:00+00:00 PythonOperator 2021-04-03T23:10:38.249167+00:00 2021-04-03T23:10:41.151849+00:00 0:00:02.902682 13282 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T23:10:35.404644+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-03T22:00:00+00:00 PythonOperator 2021-04-03T23:10:33.605543+00:00 2021-04-03T23:10:37.199766+00:00 0:00:03.594223 13281 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T23:10:31.401886+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-03T22:00:00+00:00 TriggerDagRunOperator 2021-04-03T23:10:27.680621+00:00 2021-04-03T23:10:28.215389+00:00 0:00:00.534768 13280 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T23:10:25.396543+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-03T22:00:00+00:00 TriggerDagRunOperator 2021-04-03T23:10:27.645688+00:00 2021-04-03T23:10:28.064570+00:00 0:00:00.418882 13279 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T23:10:25.396578+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-03T22:05:00+00:00 EmrJobFlowSensor 2021-04-03T23:06:01.156610+00:00 2021-04-03T23:15:03.749483+00:00 0:09:02.592873 13278 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T23:05:58.944865+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-03T22:05:00+00:00 EmrCreateJobFlowOperator 2021-04-03T23:05:39.186895+00:00 2021-04-03T23:05:40.841245+00:00 0:00:01.654350 13277 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T23:05:36.855554+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-03T22:05:00+00:00 PythonOperator 2021-04-03T23:05:16.865800+00:00 2021-04-03T23:05:19.530460+00:00 0:00:02.664660 13276 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T23:05:14.728703+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-03T22:00:00+00:00 EmrJobFlowSensor 2021-04-03T23:01:02.855353+00:00 2021-04-03T23:10:05.564487+00:00 0:09:02.709134 13275 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T23:01:00.455921+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-03T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T23:00:40.605344+00:00 2021-04-03T23:00:42.302893+00:00 0:00:01.697549 13274 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-03T23:00:38.344625+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-03T22:00:00+00:00 PythonOperator 2021-04-03T23:00:19.205981+00:00 2021-04-03T23:00:22.039622+00:00 0:00:02.833641 13273 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-03T23:00:16.372674+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-03T21:00:00+00:00 EmrJobFlowSensor 2021-04-03T22:11:12.888940+00:00 2021-04-03T22:20:15.567145+00:00 0:09:02.678205 13271 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T22:11:10.604671+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-03T21:00:00+00:00 EmrJobFlowSensor 2021-04-03T22:10:57.511601+00:00 2021-04-03T22:20:00.148006+00:00 0:09:02.636405 13270 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T22:10:54.662509+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-03T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T22:10:50.744861+00:00 2021-04-03T22:10:52.441310+00:00 0:00:01.696449 13269 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T22:10:48.588376+00:00 2 default_pool