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_booking-processing-job_v002 2021-04-06T21:00:00+00:00 TriggerDagRunOperator 2021-04-06T22:09:17.759744+00:00 2021-04-06T22:09:18.364132+00:00 0:00:00.604388 14350 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T22:09:15.317947+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-06T21:00:00+00:00 TriggerDagRunOperator 2021-04-06T22:09:17.506103+00:00 2021-04-06T22:09:17.922635+00:00 0:00:00.416532 14349 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T22:09:15.317910+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-06T21:05:00+00:00 EmrJobFlowSensor 2021-04-06T22:05:55.175137+00:00 2021-04-06T22:14:57.793072+00:00 0:09:02.617935 14348 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T22:05:53.006350+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-06T21:05:00+00:00 EmrCreateJobFlowOperator 2021-04-06T22:05:33.393812+00:00 2021-04-06T22:05:35.172867+00:00 0:00:01.779055 14347 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T22:05:31.059026+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-06T21:05:00+00:00 PythonOperator 2021-04-06T22:05:11.197248+00:00 2021-04-06T22:05:13.973222+00:00 0:00:02.775974 14346 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T22:05:09.048495+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-06T21:00:00+00:00 EmrJobFlowSensor 2021-04-06T22:01:06.979253+00:00 2021-04-06T22:09:09.567298+00:00 0:08:02.588045 14345 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T22:01:04.553060+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-06T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T22:00:44.919184+00:00 2021-04-06T22:00:46.724077+00:00 0:00:01.804893 14344 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-06T22:00:42.548679+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-06T21:00:00+00:00 PythonOperator 2021-04-06T22:00:24.747489+00:00 2021-04-06T22:00:27.542703+00:00 0:00:02.795214 14343 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-06T22:00:22.411275+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-06T20:00:00+00:00 EmrJobFlowSensor 2021-04-06T21:11:27.819540+00:00 2021-04-06T21:21:30.576393+00:00 0:10:02.756853 14341 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T21:11:25.610917+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-06T20:00:00+00:00 EmrJobFlowSensor 2021-04-06T21:11:19.995365+00:00 2021-04-06T21:19:22.510747+00:00 0:08:02.515382 14340 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T21:11:17.667108+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-06T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T21:11:06.087291+00:00 2021-04-06T21:11:07.909766+00:00 0:00:01.822475 14339 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T21:11:03.668130+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-06T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T21:10:57.942388+00:00 2021-04-06T21:10:59.618432+00:00 0:00:01.676044 14338 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T21:10:55.590312+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-06T20:00:00+00:00 PythonOperator 2021-04-06T21:10:45.860479+00:00 2021-04-06T21:10:48.935319+00:00 0:00:03.074840 14337 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T21:10:43.546821+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-06T20:00:00+00:00 PythonOperator 2021-04-06T21:10:38.160865+00:00 2021-04-06T21:10:40.919445+00:00 0:00:02.758580 14336 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T21:10:35.522341+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-06T20:00:00+00:00 TriggerDagRunOperator 2021-04-06T21:10:25.927584+00:00 2021-04-06T21:10:26.495444+00:00 0:00:00.567860 14335 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T21:10:23.613054+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-06T20:00:00+00:00 TriggerDagRunOperator 2021-04-06T21:10:25.908191+00:00 2021-04-06T21:10:26.328119+00:00 0:00:00.419928 14334 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T21:10:23.613023+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-06T20:05:00+00:00 EmrJobFlowSensor 2021-04-06T21:05:55.349373+00:00 2021-04-06T21:15:58.141572+00:00 0:10:02.792199 14333 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T21:05:53.156642+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-06T20:05:00+00:00 EmrCreateJobFlowOperator 2021-04-06T21:05:27.382942+00:00 2021-04-06T21:05:29.158597+00:00 0:00:01.775655 14332 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T21:05:25.134810+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-06T20:05:00+00:00 PythonOperator 2021-04-06T21:05:05.372797+00:00 2021-04-06T21:05:08.051537+00:00 0:00:02.678740 14331 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T21:05:03.113050+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-06T20:00:00+00:00 EmrJobFlowSensor 2021-04-06T21:01:05.266487+00:00 2021-04-06T21:10:07.903192+00:00 0:09:02.636705 14330 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T21:01:02.773883+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-06T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T21:00:42.946132+00:00 2021-04-06T21:00:44.749600+00:00 0:00:01.803468 14329 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-06T21:00:40.688721+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-06T20:00:00+00:00 PythonOperator 2021-04-06T21:00:23.135839+00:00 2021-04-06T21:00:26.487466+00:00 0:00:03.351627 14328 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-06T21:00:20.658486+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-06T19:00:00+00:00 EmrJobFlowSensor 2021-04-06T20:11:34.456746+00:00 2021-04-06T20:20:37.036689+00:00 0:09:02.579943 14326 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T20:11:32.185886+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-06T19:00:00+00:00 EmrJobFlowSensor 2021-04-06T20:11:24.629561+00:00 2021-04-06T20:21:27.345376+00:00 0:10:02.715815 14325 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T20:11:22.160623+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-06T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T20:11:12.328214+00:00 2021-04-06T20:11:14.055337+00:00 0:00:01.727123 14324 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T20:11:10.149672+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-06T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T20:11:04.458799+00:00 2021-04-06T20:11:06.319965+00:00 0:00:01.861166 14323 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T20:11:02.140671+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-06T19:00:00+00:00 PythonOperator 2021-04-06T20:10:50.514855+00:00 2021-04-06T20:10:53.327306+00:00 0:00:02.812451 14322 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T20:10:48.147521+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-06T19:00:00+00:00 PythonOperator 2021-04-06T20:10:40.802213+00:00 2021-04-06T20:10:43.766265+00:00 0:00:02.964052 14321 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T20:10:38.071801+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-06T19:00:00+00:00 TriggerDagRunOperator 2021-04-06T20:10:28.612786+00:00 2021-04-06T20:10:29.131088+00:00 0:00:00.518302 14320 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T20:10:26.071178+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-06T19:00:00+00:00 TriggerDagRunOperator 2021-04-06T20:10:28.413455+00:00 2021-04-06T20:10:28.862405+00:00 0:00:00.448950 14319 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T20:10:26.071217+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-06T19:05:00+00:00 EmrJobFlowSensor 2021-04-06T20:06:01.968956+00:00 2021-04-06T20:15:04.586909+00:00 0:09:02.617953 14318 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T20:05:59.687286+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-06T19:05:00+00:00 EmrCreateJobFlowOperator 2021-04-06T20:05:39.878073+00:00 2021-04-06T20:05:41.649652+00:00 0:00:01.771579 14317 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T20:05:37.634282+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-06T19:05:00+00:00 PythonOperator 2021-04-06T20:05:19.883632+00:00 2021-04-06T20:05:22.647945+00:00 0:00:02.764313 14316 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T20:05:17.617152+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-06T19:00:00+00:00 EmrJobFlowSensor 2021-04-06T20:01:07.370937+00:00 2021-04-06T20:10:10.125106+00:00 0:09:02.754169 14315 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T20:01:05.167627+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-06T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T20:00:43.376481+00:00 2021-04-06T20:00:45.192442+00:00 0:00:01.815961 14314 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-06T20:00:41.105375+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-06T19:00:00+00:00 PythonOperator 2021-04-06T20:00:15.911929+00:00 2021-04-06T20:00:18.640750+00:00 0:00:02.728821 14313 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-06T20:00:13.152395+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-06T18:00:00+00:00 EmrJobFlowSensor 2021-04-06T19:12:19.426417+00:00 2021-04-06T19:21:22.145232+00:00 0:09:02.718815 14311 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T19:12:17.040991+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-06T18:00:00+00:00 EmrJobFlowSensor 2021-04-06T19:12:13.252896+00:00 2021-04-06T19:24:16.385089+00:00 0:12:03.132193 14310 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T19:12:10.916864+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-06T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T19:11:57.300303+00:00 2021-04-06T19:11:59.095930+00:00 0:00:01.795627 14309 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T19:11:54.967402+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-06T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T19:11:51.399893+00:00 2021-04-06T19:11:53.086959+00:00 0:00:01.687066 14308 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T19:11:48.960588+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-06T18:00:00+00:00 PythonOperator 2021-04-06T19:11:37.208154+00:00 2021-04-06T19:11:39.946597+00:00 0:00:02.738443 14307 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T19:11:34.895291+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-06T18:00:00+00:00 PythonOperator 2021-04-06T19:11:31.846844+00:00 2021-04-06T19:11:34.732633+00:00 0:00:02.885789 14306 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T19:11:28.974500+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-06T18:00:00+00:00 TriggerDagRunOperator 2021-04-06T19:11:19.312315+00:00 2021-04-06T19:11:19.756437+00:00 0:00:00.444122 14305 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T19:11:16.844691+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-06T18:00:00+00:00 TriggerDagRunOperator 2021-04-06T19:11:19.222396+00:00 2021-04-06T19:11:19.779832+00:00 0:00:00.557436 14304 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T19:11:16.844720+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-06T18:05:00+00:00 EmrJobFlowSensor 2021-04-06T19:05:58.397769+00:00 2021-04-06T19:15:00.958204+00:00 0:09:02.560435 14303 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T19:05:56.215583+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-06T18:05:00+00:00 EmrCreateJobFlowOperator 2021-04-06T19:05:36.358825+00:00 2021-04-06T19:05:38.019731+00:00 0:00:01.660906 14302 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T19:05:34.198266+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-06T18:05:00+00:00 PythonOperator 2021-04-06T19:05:12.373639+00:00 2021-04-06T19:05:15.094922+00:00 0:00:02.721283 14301 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T19:05:10.176130+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-06T18:00:00+00:00 EmrJobFlowSensor 2021-04-06T19:00:56.151334+00:00 2021-04-06T19:10:59.060697+00:00 0:10:02.909363 14300 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T19:00:53.883008+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-06T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T19:00:36.113845+00:00 2021-04-06T19:00:37.777288+00:00 0:00:01.663443 14299 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-06T19:00:33.857345+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-06T18:00:00+00:00 PythonOperator 2021-04-06T19:00:12.597726+00:00 2021-04-06T19:00:15.488982+00:00 0:00:02.891256 14298 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-06T19:00:09.790649+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-06T17:00:00+00:00 EmrJobFlowSensor 2021-04-06T18:11:28.922500+00:00 2021-04-06T18:21:31.765915+00:00 0:10:02.843415 14296 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T18:11:26.618998+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-06T17:00:00+00:00 EmrJobFlowSensor 2021-04-06T18:11:14.934629+00:00 2021-04-06T18:20:17.483130+00:00 0:09:02.548501 14295 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T18:11:12.607938+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-06T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T18:11:06.896904+00:00 2021-04-06T18:11:08.597335+00:00 0:00:01.700431 14294 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T18:11:04.603862+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-06T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T18:10:52.900914+00:00 2021-04-06T18:10:54.604907+00:00 0:00:01.703993 14293 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T18:10:50.589001+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-06T17:00:00+00:00 PythonOperator 2021-04-06T18:10:45.082174+00:00 2021-04-06T18:10:48.305680+00:00 0:00:03.223506 14292 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T18:10:42.647104+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-06T17:00:00+00:00 PythonOperator 2021-04-06T18:10:30.928042+00:00 2021-04-06T18:10:33.709374+00:00 0:00:02.781332 14291 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T18:10:28.583976+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-06T17:00:00+00:00 TriggerDagRunOperator 2021-04-06T18:10:26.856097+00:00 2021-04-06T18:10:27.280328+00:00 0:00:00.424231 14290 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T18:10:24.496809+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-06T17:00:00+00:00 TriggerDagRunOperator 2021-04-06T18:10:26.843482+00:00 2021-04-06T18:10:27.372307+00:00 0:00:00.528825 14289 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T18:10:24.496781+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-06T17:05:00+00:00 EmrJobFlowSensor 2021-04-06T18:05:54.619042+00:00 2021-04-06T18:14:57.319298+00:00 0:09:02.700256 14288 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T18:05:52.101290+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-06T17:05:00+00:00 EmrCreateJobFlowOperator 2021-04-06T18:05:34.359753+00:00 2021-04-06T18:05:36.128726+00:00 0:00:01.768973 14287 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T18:05:32.086849+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-06T17:05:00+00:00 PythonOperator 2021-04-06T18:05:12.177260+00:00 2021-04-06T18:05:15.072775+00:00 0:00:02.895515 14286 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T18:05:10.013371+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-06T17:00:00+00:00 EmrJobFlowSensor 2021-04-06T18:01:04.054468+00:00 2021-04-06T18:10:06.887176+00:00 0:09:02.832708 14285 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T18:01:01.655696+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-06T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T18:00:30.089162+00:00 2021-04-06T18:00:31.899599+00:00 0:00:01.810437 14284 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-06T18:00:27.652479+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-06T17:00:00+00:00 PythonOperator 2021-04-06T18:00:08.400428+00:00 2021-04-06T18:00:11.240143+00:00 0:00:02.839715 14283 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-06T18:00:05.609970+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-06T16:00:00+00:00 EmrJobFlowSensor 2021-04-06T17:21:57.969131+00:00 2021-04-06T17:21:59.555228+00:00 0:00:01.586097 14281 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T17:21:55.480395+00:00 3 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-06T16:00:00+00:00 EmrJobFlowSensor 2021-04-06T17:10:20.607212+00:00 2021-04-06T17:20:23.345215+00:00 0:10:02.738003 14280 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T17:10:18.316811+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-06T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T17:09:58.602597+00:00 2021-04-06T17:10:00.317992+00:00 0:00:01.715395 14278 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T17:09:56.284689+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-06T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T17:09:54.544355+00:00 2021-04-06T17:09:56.347587+00:00 0:00:01.803232 14277 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T17:09:52.259771+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-06T16:00:00+00:00 PythonOperator 2021-04-06T17:09:36.526616+00:00 2021-04-06T17:09:39.343406+00:00 0:00:02.816790 14276 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T17:09:34.270785+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-06T16:00:00+00:00 PythonOperator 2021-04-06T17:09:34.713179+00:00 2021-04-06T17:09:37.671200+00:00 0:00:02.958021 14275 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T17:09:32.238382+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-06T16:00:00+00:00 TriggerDagRunOperator 2021-04-06T17:09:22.596280+00:00 2021-04-06T17:09:23.124097+00:00 0:00:00.527817 14274 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T17:09:20.229775+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-06T16:00:00+00:00 TriggerDagRunOperator 2021-04-06T17:09:22.449184+00:00 2021-04-06T17:09:22.908696+00:00 0:00:00.459512 14273 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T17:09:20.229810+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-06T16:05:00+00:00 EmrJobFlowSensor 2021-04-06T17:05:48.333855+00:00 2021-04-06T17:14:50.925819+00:00 0:09:02.591964 14272 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T17:05:45.984454+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-06T16:05:00+00:00 EmrCreateJobFlowOperator 2021-04-06T17:05:26.193643+00:00 2021-04-06T17:05:27.969801+00:00 0:00:01.776158 14271 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T17:05:23.943042+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-06T16:05:00+00:00 PythonOperator 2021-04-06T17:05:06.796740+00:00 2021-04-06T17:05:09.520083+00:00 0:00:02.723343 14270 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T17:05:03.922375+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-06T16:00:00+00:00 EmrJobFlowSensor 2021-04-06T17:00:55.998810+00:00 2021-04-06T17:08:58.407249+00:00 0:08:02.408439 14269 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T17:00:53.666362+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-06T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T17:00:36.046022+00:00 2021-04-06T17:00:37.869881+00:00 0:00:01.823859 14268 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-06T17:00:33.661745+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-06T16:00:00+00:00 PythonOperator 2021-04-06T17:00:14.452079+00:00 2021-04-06T17:00:17.330953+00:00 0:00:02.878874 14267 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-06T17:00:11.594035+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-06T15:00:00+00:00 EmrJobFlowSensor 2021-04-06T16:11:23.923378+00:00 2021-04-06T16:20:26.635369+00:00 0:09:02.711991 14265 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T16:11:21.633525+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-06T15:00:00+00:00 EmrJobFlowSensor 2021-04-06T16:11:19.807389+00:00 2021-04-06T16:22:22.585867+00:00 0:11:02.778478 14264 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T16:11:17.629138+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-06T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T16:11:00.690189+00:00 2021-04-06T16:11:02.442549+00:00 0:00:01.752360 14263 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T16:10:57.609531+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-06T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T16:10:58.534729+00:00 2021-04-06T16:11:00.573971+00:00 0:00:02.039242 14262 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T16:10:55.609137+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-06T15:00:00+00:00 PythonOperator 2021-04-06T16:10:38.256274+00:00 2021-04-06T16:10:41.046097+00:00 0:00:02.789823 14261 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T16:10:35.596332+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-06T15:00:00+00:00 PythonOperator 2021-04-06T16:10:36.209211+00:00 2021-04-06T16:10:39.118048+00:00 0:00:02.908837 14260 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T16:10:33.596643+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-06T15:00:00+00:00 TriggerDagRunOperator 2021-04-06T16:10:18.430264+00:00 2021-04-06T16:10:18.961118+00:00 0:00:00.530854 14259 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T16:10:15.543812+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-06T15:00:00+00:00 TriggerDagRunOperator 2021-04-06T16:10:18.290923+00:00 2021-04-06T16:10:18.698856+00:00 0:00:00.407933 14258 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T16:10:15.543776+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-06T15:05:00+00:00 EmrJobFlowSensor 2021-04-06T16:05:59.090882+00:00 2021-04-06T16:15:01.670311+00:00 0:09:02.579429 14257 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T16:05:56.865719+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-06T15:05:00+00:00 EmrCreateJobFlowOperator 2021-04-06T16:05:37.043476+00:00 2021-04-06T16:05:38.671577+00:00 0:00:01.628101 14256 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T16:05:34.853190+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-06T15:05:00+00:00 PythonOperator 2021-04-06T16:05:17.000403+00:00 2021-04-06T16:05:19.747579+00:00 0:00:02.747176 14255 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T16:05:14.751800+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-06T15:00:00+00:00 EmrJobFlowSensor 2021-04-06T16:00:54.820690+00:00 2021-04-06T16:09:57.524526+00:00 0:09:02.703836 14254 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T16:00:52.375248+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-06T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T16:00:34.525273+00:00 2021-04-06T16:00:36.228858+00:00 0:00:01.703585 14253 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-06T16:00:32.284725+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-06T15:00:00+00:00 PythonOperator 2021-04-06T16:00:12.790476+00:00 2021-04-06T16:00:15.538256+00:00 0:00:02.747780 14252 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-06T16:00:10.220164+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-06T14:00:00+00:00 EmrJobFlowSensor 2021-04-06T15:12:16.702987+00:00 2021-04-06T15:21:19.400771+00:00 0:09:02.697784 14250 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T15:12:14.451403+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-06T14:00:00+00:00 EmrJobFlowSensor 2021-04-06T15:12:00.802148+00:00 2021-04-06T15:22:03.723409+00:00 0:10:02.921261 14249 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T15:11:58.363768+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-06T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T15:11:56.637432+00:00 2021-04-06T15:11:58.333016+00:00 0:00:01.695584 14248 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T15:11:54.351086+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-06T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T15:11:40.536019+00:00 2021-04-06T15:11:42.330713+00:00 0:00:01.794694 14247 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T15:11:38.241960+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-06T14:00:00+00:00 PythonOperator 2021-04-06T15:11:34.514044+00:00 2021-04-06T15:11:37.217243+00:00 0:00:02.703199 14246 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T15:11:32.237346+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-06T14:00:00+00:00 PythonOperator 2021-04-06T15:11:18.850361+00:00 2021-04-06T15:11:21.947405+00:00 0:00:03.097044 14245 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T15:11:16.221693+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-06T14:00:00+00:00 TriggerDagRunOperator 2021-04-06T15:11:12.741542+00:00 2021-04-06T15:11:13.169844+00:00 0:00:00.428302 14244 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T15:11:10.216527+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-06T14:00:00+00:00 TriggerDagRunOperator 2021-04-06T15:11:12.438966+00:00 2021-04-06T15:11:12.975269+00:00 0:00:00.536303 14243 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T15:11:10.216563+00:00 2 default_pool