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 create_emr_steps 2021-03-21T23:00:00+00:00 PythonOperator 2021-03-22T00:00:15.630735+00:00 2021-03-22T00:00:18.365557+00:00 0:00:02.734822 10395 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-22T00:00:13.303517+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-21T22:00:00+00:00 EmrJobFlowSensor 2021-03-21T23:11:33.267227+00:00 2021-03-21T23:20:36.029104+00:00 0:09:02.761877 10393 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-21T23:11:30.954689+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-21T22:00:00+00:00 EmrCreateJobFlowOperator 2021-03-21T23:11:03.208259+00:00 2021-03-21T23:11:04.934639+00:00 0:00:01.726380 10392 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-21T23:11:00.929529+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-21T22:00:00+00:00 PythonOperator 2021-03-21T23:10:39.282916+00:00 2021-03-21T23:10:42.184330+00:00 0:00:02.901414 10391 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-21T23:10:36.888322+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-21T22:00:00+00:00 TriggerDagRunOperator 2021-03-21T23:10:21.232081+00:00 2021-03-21T23:10:21.776001+00:00 0:00:00.543920 10390 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-21T23:10:18.860239+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-21T22:00:00+00:00 TriggerDagRunOperator 2021-03-21T23:10:21.159063+00:00 2021-03-21T23:10:21.575180+00:00 0:00:00.416117 10389 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-21T23:10:18.860286+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-21T22:00:00+00:00 EmrJobFlowSensor 2021-03-21T23:01:02.017225+00:00 2021-03-21T23:10:04.745804+00:00 0:09:02.728579 10388 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-21T23:00:59.814462+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-21T22:00:00+00:00 EmrCreateJobFlowOperator 2021-03-21T23:00:40.021452+00:00 2021-03-21T23:00:41.707738+00:00 0:00:01.686286 10387 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-21T23:00:37.794258+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-21T22:00:00+00:00 PythonOperator 2021-03-21T23:00:18.076724+00:00 2021-03-21T23:00:20.768070+00:00 0:00:02.691346 10386 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-21T23:00:15.777523+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-21T21:00:00+00:00 EmrJobFlowSensor 2021-03-21T22:11:38.809831+00:00 2021-03-21T22:21:41.439056+00:00 0:10:02.629225 10384 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-21T22:11:36.360940+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-21T21:00:00+00:00 EmrCreateJobFlowOperator 2021-03-21T22:11:22.757959+00:00 2021-03-21T22:11:24.645430+00:00 0:00:01.887471 10383 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-21T22:11:20.300205+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-21T21:00:00+00:00 PythonOperator 2021-03-21T22:11:06.398310+00:00 2021-03-21T22:11:09.182267+00:00 0:00:02.783957 10382 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-21T22:11:04.264916+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-21T21:00:00+00:00 TriggerDagRunOperator 2021-03-21T22:10:14.716500+00:00 2021-03-21T22:10:15.268492+00:00 0:00:00.551992 10381 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-21T22:10:12.197230+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-21T21:00:00+00:00 TriggerDagRunOperator 2021-03-21T22:10:14.632840+00:00 2021-03-21T22:10:15.083596+00:00 0:00:00.450756 10380 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-21T22:10:12.197262+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-21T21:00:00+00:00 EmrJobFlowSensor 2021-03-21T22:00:55.630564+00:00 2021-03-21T22:09:58.279922+00:00 0:09:02.649358 10379 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-21T22:00:53.161999+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-21T21:00:00+00:00 EmrCreateJobFlowOperator 2021-03-21T22:00:25.457803+00:00 2021-03-21T22:00:27.160162+00:00 0:00:01.702359 10378 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-21T22:00:23.090309+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-21T21:00:00+00:00 PythonOperator 2021-03-21T22:00:03.755822+00:00 2021-03-21T22:00:06.600945+00:00 0:00:02.845123 10377 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-21T22:00:01.125042+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-21T20:00:00+00:00 EmrJobFlowSensor 2021-03-21T21:11:52.001658+00:00 2021-03-21T21:20:54.654108+00:00 0:09:02.652450 10375 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-21T21:11:49.795045+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-21T20:00:00+00:00 EmrCreateJobFlowOperator 2021-03-21T21:11:31.985039+00:00 2021-03-21T21:11:33.650326+00:00 0:00:01.665287 10374 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-21T21:11:29.829208+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-21T20:00:00+00:00 PythonOperator 2021-03-21T21:11:16.163314+00:00 2021-03-21T21:11:18.918793+00:00 0:00:02.755479 10373 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-21T21:11:13.763894+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-21T20:00:00+00:00 TriggerDagRunOperator 2021-03-21T21:11:08.491940+00:00 2021-03-21T21:11:09.034354+00:00 0:00:00.542414 10372 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-21T21:11:05.817935+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-21T20:00:00+00:00 TriggerDagRunOperator 2021-03-21T21:11:08.216758+00:00 2021-03-21T21:11:08.642514+00:00 0:00:00.425756 10371 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-21T21:11:05.817900+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-21T20:00:00+00:00 EmrJobFlowSensor 2021-03-21T21:00:51.098991+00:00 2021-03-21T21:10:53.780892+00:00 0:10:02.681901 10370 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-21T21:00:48.650678+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-21T20:00:00+00:00 EmrCreateJobFlowOperator 2021-03-21T21:00:32.799299+00:00 2021-03-21T21:00:34.517956+00:00 0:00:01.718657 10369 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-21T21:00:30.584909+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-21T20:00:00+00:00 PythonOperator 2021-03-21T21:00:15.566626+00:00 2021-03-21T21:00:18.535971+00:00 0:00:02.969345 10368 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-21T21:00:12.636972+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-21T19:00:00+00:00 EmrJobFlowSensor 2021-03-21T20:12:03.697134+00:00 2021-03-21T20:30:07.325076+00:00 0:18:03.627942 10366 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-21T20:12:01.507128+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-21T19:00:00+00:00 EmrCreateJobFlowOperator 2021-03-21T20:11:47.801956+00:00 2021-03-21T20:11:49.649150+00:00 0:00:01.847194 10365 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-21T20:11:45.485219+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-21T19:00:00+00:00 PythonOperator 2021-03-21T20:11:29.885693+00:00 2021-03-21T20:11:32.670746+00:00 0:00:02.785053 10364 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-21T20:11:27.534171+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-21T19:00:00+00:00 TriggerDagRunOperator 2021-03-21T20:11:12.024103+00:00 2021-03-21T20:11:12.608188+00:00 0:00:00.584085 10363 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-21T20:11:09.524739+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-21T19:00:00+00:00 TriggerDagRunOperator 2021-03-21T20:11:11.900699+00:00 2021-03-21T20:11:12.280909+00:00 0:00:00.380210 10362 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-21T20:11:09.524786+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-21T19:00:00+00:00 EmrJobFlowSensor 2021-03-21T20:00:54.392392+00:00 2021-03-21T20:10:57.313620+00:00 0:10:02.921228 10361 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-21T20:00:51.863126+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-21T19:00:00+00:00 EmrCreateJobFlowOperator 2021-03-21T20:00:36.010966+00:00 2021-03-21T20:00:37.679310+00:00 0:00:01.668344 10360 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-21T20:00:33.809998+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-21T19:00:00+00:00 PythonOperator 2021-03-21T20:00:06.266310+00:00 2021-03-21T20:00:09.143104+00:00 0:00:02.876794 10359 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-21T20:00:03.785565+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-21T18:00:00+00:00 EmrJobFlowSensor 2021-03-21T19:11:20.706293+00:00 2021-03-21T19:21:23.392458+00:00 0:10:02.686165 10357 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-21T19:11:18.455285+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-21T18:00:00+00:00 EmrCreateJobFlowOperator 2021-03-21T19:10:58.560392+00:00 2021-03-21T19:11:00.288228+00:00 0:00:01.727836 10356 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-21T19:10:56.378642+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-21T18:00:00+00:00 PythonOperator 2021-03-21T19:10:32.589569+00:00 2021-03-21T19:10:35.271985+00:00 0:00:02.682416 10355 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-21T19:10:30.355505+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-21T18:00:00+00:00 TriggerDagRunOperator 2021-03-21T19:10:14.806912+00:00 2021-03-21T19:10:15.321429+00:00 0:00:00.514517 10354 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-21T19:10:12.333964+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-21T18:00:00+00:00 TriggerDagRunOperator 2021-03-21T19:10:14.678888+00:00 2021-03-21T19:10:15.103079+00:00 0:00:00.424191 10353 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-21T19:10:12.333993+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-21T18:00:00+00:00 EmrJobFlowSensor 2021-03-21T19:00:53.400313+00:00 2021-03-21T19:09:56.034727+00:00 0:09:02.634414 10352 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-21T19:00:51.130533+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-21T18:00:00+00:00 EmrCreateJobFlowOperator 2021-03-21T19:00:35.368209+00:00 2021-03-21T19:00:37.063169+00:00 0:00:01.694960 10351 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-21T19:00:33.059213+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-21T18:00:00+00:00 PythonOperator 2021-03-21T19:00:19.594289+00:00 2021-03-21T19:00:22.447039+00:00 0:00:02.852750 10350 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-21T19:00:16.964395+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-21T17:00:00+00:00 EmrJobFlowSensor 2021-03-21T18:11:04.542880+00:00 2021-03-21T18:20:07.064322+00:00 0:09:02.521442 10348 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-21T18:11:02.164132+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-21T17:00:00+00:00 EmrCreateJobFlowOperator 2021-03-21T18:10:48.523552+00:00 2021-03-21T18:10:50.416500+00:00 0:00:01.892948 10347 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-21T18:10:46.115259+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-21T17:00:00+00:00 PythonOperator 2021-03-21T18:10:33.072861+00:00 2021-03-21T18:10:35.769492+00:00 0:00:02.696631 10346 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-21T18:10:30.152575+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-21T17:00:00+00:00 TriggerDagRunOperator 2021-03-21T18:10:20.863618+00:00 2021-03-21T18:10:21.384354+00:00 0:00:00.520736 10345 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-21T18:10:18.115421+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-21T17:00:00+00:00 TriggerDagRunOperator 2021-03-21T18:10:20.677651+00:00 2021-03-21T18:10:21.069222+00:00 0:00:00.391571 10344 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-21T18:10:18.115473+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-21T17:00:00+00:00 EmrJobFlowSensor 2021-03-21T18:01:01.304005+00:00 2021-03-21T18:10:04.082510+00:00 0:09:02.778505 10343 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-21T18:00:58.960826+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-21T17:00:00+00:00 EmrCreateJobFlowOperator 2021-03-21T18:00:45.488247+00:00 2021-03-21T18:00:47.368143+00:00 0:00:01.879896 10342 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-21T18:00:43.018156+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-21T17:00:00+00:00 PythonOperator 2021-03-21T18:00:11.119895+00:00 2021-03-21T18:00:13.840051+00:00 0:00:02.720156 10341 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-21T18:00:08.873077+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-21T16:00:00+00:00 EmrJobFlowSensor 2021-03-21T17:11:37.972239+00:00 2021-03-21T17:21:40.590697+00:00 0:10:02.618458 10339 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-21T17:11:35.696705+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-21T16:00:00+00:00 EmrCreateJobFlowOperator 2021-03-21T17:11:20.114982+00:00 2021-03-21T17:11:21.827205+00:00 0:00:01.712223 10338 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-21T17:11:17.687955+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-21T16:00:00+00:00 PythonOperator 2021-03-21T17:11:04.479588+00:00 2021-03-21T17:11:07.374720+00:00 0:00:02.895132 10337 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-21T17:11:01.733358+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-21T16:00:00+00:00 TriggerDagRunOperator 2021-03-21T17:10:55.966467+00:00 2021-03-21T17:10:56.502286+00:00 0:00:00.535819 10336 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-21T17:10:53.664628+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-21T16:00:00+00:00 TriggerDagRunOperator 2021-03-21T17:10:55.916543+00:00 2021-03-21T17:10:56.304927+00:00 0:00:00.388384 10335 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-21T17:10:53.664590+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-21T16:00:00+00:00 EmrJobFlowSensor 2021-03-21T17:00:38.511955+00:00 2021-03-21T17:10:41.336074+00:00 0:10:02.824119 10334 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-21T17:00:36.286574+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-21T16:00:00+00:00 EmrCreateJobFlowOperator 2021-03-21T17:00:22.551766+00:00 2021-03-21T17:00:24.410174+00:00 0:00:01.858408 10333 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-21T17:00:20.255256+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-21T16:00:00+00:00 PythonOperator 2021-03-21T17:00:06.603333+00:00 2021-03-21T17:00:09.487092+00:00 0:00:02.883759 10332 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-21T17:00:04.185606+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-21T15:00:00+00:00 EmrJobFlowSensor 2021-03-21T16:10:44.938017+00:00 2021-03-21T16:19:47.807602+00:00 0:09:02.869585 10330 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-21T16:10:42.342324+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-21T15:00:00+00:00 EmrCreateJobFlowOperator 2021-03-21T16:10:28.606527+00:00 2021-03-21T16:10:30.293005+00:00 0:00:01.686478 10329 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-21T16:10:26.325094+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-21T15:00:00+00:00 PythonOperator 2021-03-21T16:10:12.441228+00:00 2021-03-21T16:10:15.323843+00:00 0:00:02.882615 10328 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-21T16:10:10.197590+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-21T15:00:00+00:00 TriggerDagRunOperator 2021-03-21T16:09:56.872104+00:00 2021-03-21T16:09:57.262436+00:00 0:00:00.390332 10327 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-21T16:09:54.189628+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-21T15:00:00+00:00 TriggerDagRunOperator 2021-03-21T16:09:56.605921+00:00 2021-03-21T16:09:57.157489+00:00 0:00:00.551568 10326 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-21T16:09:54.189587+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-21T15:00:00+00:00 EmrJobFlowSensor 2021-03-21T16:00:41.711728+00:00 2021-03-21T16:09:44.250223+00:00 0:09:02.538495 10325 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-21T16:00:39.520868+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-21T15:00:00+00:00 EmrCreateJobFlowOperator 2021-03-21T16:00:25.606583+00:00 2021-03-21T16:00:27.308846+00:00 0:00:01.702263 10324 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-21T16:00:23.257518+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-21T15:00:00+00:00 PythonOperator 2021-03-21T16:00:07.626029+00:00 2021-03-21T16:00:10.319609+00:00 0:00:02.693580 10323 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-21T16:00:05.167080+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-21T14:00:00+00:00 EmrJobFlowSensor 2021-03-21T15:11:40.428744+00:00 2021-03-21T15:19:43.039555+00:00 0:08:02.610811 10321 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-21T15:11:38.170433+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-21T14:00:00+00:00 EmrCreateJobFlowOperator 2021-03-21T15:11:22.711362+00:00 2021-03-21T15:11:24.538391+00:00 0:00:01.827029 10320 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-21T15:11:20.221638+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-21T14:00:00+00:00 PythonOperator 2021-03-21T15:11:06.594820+00:00 2021-03-21T15:11:09.270641+00:00 0:00:02.675821 10319 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-21T15:11:04.120621+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-21T14:00:00+00:00 TriggerDagRunOperator 2021-03-21T15:10:54.614595+00:00 2021-03-21T15:10:55.145649+00:00 0:00:00.531054 10318 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-21T15:10:52.108727+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-21T14:00:00+00:00 TriggerDagRunOperator 2021-03-21T15:10:54.339691+00:00 2021-03-21T15:10:54.745245+00:00 0:00:00.405554 10317 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-21T15:10:52.108699+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-21T14:00:00+00:00 EmrJobFlowSensor 2021-03-21T15:00:39.251478+00:00 2021-03-21T15:10:41.913987+00:00 0:10:02.662509 10316 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-21T15:00:37.080744+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-21T14:00:00+00:00 EmrCreateJobFlowOperator 2021-03-21T15:00:23.765167+00:00 2021-03-21T15:00:25.731280+00:00 0:00:01.966113 10315 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-21T15:00:21.135759+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-21T14:00:00+00:00 PythonOperator 2021-03-21T15:00:05.555149+00:00 2021-03-21T15:00:08.440558+00:00 0:00:02.885409 10314 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-21T15:00:03.058540+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-21T13:00:00+00:00 EmrJobFlowSensor 2021-03-21T14:11:16.196594+00:00 2021-03-21T14:20:18.961239+00:00 0:09:02.764645 10312 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-21T14:11:13.782736+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-21T13:00:00+00:00 EmrCreateJobFlowOperator 2021-03-21T14:11:00.178793+00:00 2021-03-21T14:11:01.924631+00:00 0:00:01.745838 10311 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-21T14:10:57.817672+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-21T13:00:00+00:00 PythonOperator 2021-03-21T14:10:44.486070+00:00 2021-03-21T14:10:47.235467+00:00 0:00:02.749397 10310 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-21T14:10:41.830312+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-21T13:00:00+00:00 TriggerDagRunOperator 2021-03-21T14:10:36.173679+00:00 2021-03-21T14:10:36.722503+00:00 0:00:00.548824 10309 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-21T14:10:33.700324+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-21T13:00:00+00:00 TriggerDagRunOperator 2021-03-21T14:10:36.035741+00:00 2021-03-21T14:10:36.423394+00:00 0:00:00.387653 10308 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-21T14:10:33.700288+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-21T13:00:00+00:00 EmrJobFlowSensor 2021-03-21T14:01:21.310056+00:00 2021-03-21T14:10:24.065067+00:00 0:09:02.755011 10307 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-21T14:01:18.835326+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-21T13:00:00+00:00 EmrCreateJobFlowOperator 2021-03-21T14:01:05.012171+00:00 2021-03-21T14:01:06.694109+00:00 0:00:01.681938 10306 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-21T14:01:02.720963+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-21T13:00:00+00:00 PythonOperator 2021-03-21T14:00:43.065181+00:00 2021-03-21T14:00:45.767974+00:00 0:00:02.702793 10305 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-21T14:00:40.673102+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-21T12:00:00+00:00 EmrJobFlowSensor 2021-03-21T13:15:56.540022+00:00 2021-03-21T13:25:59.486952+00:00 0:10:02.946930 10304 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-21T13:15:54.160793+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-21T12:00:00+00:00 EmrCreateJobFlowOperator 2021-03-21T13:15:40.205111+00:00 2021-03-21T13:15:41.904062+00:00 0:00:01.698951 10303 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-21T13:15:38.079763+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-21T12:00:00+00:00 PythonOperator 2021-03-21T13:15:24.633704+00:00 2021-03-21T13:15:27.477212+00:00 0:00:02.843508 10302 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-21T13:15:22.065399+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-21T12:00:00+00:00 TriggerDagRunOperator 2021-03-21T13:15:14.915063+00:00 2021-03-21T13:15:15.478336+00:00 0:00:00.563273 10301 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-21T13:15:11.932216+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-21T12:00:00+00:00 TriggerDagRunOperator 2021-03-21T13:15:14.824467+00:00 2021-03-21T13:15:15.233899+00:00 0:00:00.409432 10300 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-21T13:15:11.932164+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-21T12:00:00+00:00 EmrJobFlowSensor 2021-03-21T13:00:52.939264+00:00 2021-03-21T13:09:55.696579+00:00 0:09:02.757315 10298 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-21T13:00:50.535613+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-21T12:00:00+00:00 EmrCreateJobFlowOperator 2021-03-21T13:00:36.746203+00:00 2021-03-21T13:00:38.474956+00:00 0:00:01.728753 10297 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-21T13:00:34.469811+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-21T12:00:00+00:00 PythonOperator 2021-03-21T13:00:21.073332+00:00 2021-03-21T13:00:23.999105+00:00 0:00:02.925773 10296 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-21T13:00:18.538488+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-21T11:00:00+00:00 EmrJobFlowSensor 2021-03-21T12:11:51.413908+00:00 2021-03-21T12:20:54.117653+00:00 0:09:02.703745 10295 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-21T12:11:49.231313+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-21T11:00:00+00:00 EmrCreateJobFlowOperator 2021-03-21T12:11:33.841930+00:00 2021-03-21T12:11:35.684345+00:00 0:00:01.842415 10294 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-21T12:11:31.230449+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-21T11:00:00+00:00 PythonOperator 2021-03-21T12:11:17.682626+00:00 2021-03-21T12:11:20.396261+00:00 0:00:02.713635 10293 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-21T12:11:15.228215+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-21T11:00:00+00:00 TriggerDagRunOperator 2021-03-21T12:10:59.712027+00:00 2021-03-21T12:11:00.263401+00:00 0:00:00.551374 10292 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-21T12:10:57.102344+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-21T11:00:00+00:00 TriggerDagRunOperator 2021-03-21T12:10:59.552299+00:00 2021-03-21T12:10:59.974339+00:00 0:00:00.422040 10291 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-21T12:10:57.102372+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-21T11:00:00+00:00 EmrJobFlowSensor 2021-03-21T12:00:42.621409+00:00 2021-03-21T12:10:45.610804+00:00 0:10:02.989395 10289 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-21T12:00:40.047360+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-21T11:00:00+00:00 EmrCreateJobFlowOperator 2021-03-21T12:00:26.446066+00:00 2021-03-21T12:00:28.134636+00:00 0:00:01.688570 10288 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-21T12:00:24.043944+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-21T11:00:00+00:00 PythonOperator 2021-03-21T12:00:08.125997+00:00 2021-03-21T12:00:10.849703+00:00 0:00:02.723706 10287 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-21T12:00:05.890245+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-21T10:00:00+00:00 EmrJobFlowSensor 2021-03-21T11:11:56.592741+00:00 2021-03-21T11:21:59.361936+00:00 0:10:02.769195 10286 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-21T11:11:54.372665+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-21T10:00:00+00:00 EmrCreateJobFlowOperator 2021-03-21T11:11:40.515208+00:00 2021-03-21T11:11:42.215301+00:00 0:00:01.700093 10285 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-21T11:11:38.319496+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-21T10:00:00+00:00 PythonOperator 2021-03-21T11:11:24.762124+00:00 2021-03-21T11:11:27.462093+00:00 0:00:02.699969 10284 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-21T11:11:22.315359+00:00 2 default_pool