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 check_cluster_status 2021-04-13T07:00:00+00:00 EmrJobFlowSensor 2021-04-13T08:01:01.101414+00:00 2021-04-13T08:10:03.954008+00:00 0:09:02.852594 16655 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T08:00:58.474415+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-13T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-13T08:00:40.524170+00:00 2021-04-13T08:00:42.199539+00:00 0:00:01.675369 16654 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-13T08:00:38.345213+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-13T07:00:00+00:00 PythonOperator 2021-04-13T08:00:19.130243+00:00 2021-04-13T08:00:21.982296+00:00 0:00:02.852053 16653 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-13T08:00:16.329406+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-13T06:00:00+00:00 EmrJobFlowSensor 2021-04-13T07:12:12.155059+00:00 2021-04-13T07:21:14.960722+00:00 0:09:02.805663 16651 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T07:12:09.922913+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-13T06:00:00+00:00 EmrJobFlowSensor 2021-04-13T07:11:58.164619+00:00 2021-04-13T07:22:01.113557+00:00 0:10:02.948938 16650 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T07:11:55.909505+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-13T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-13T07:11:52.143364+00:00 2021-04-13T07:11:53.942033+00:00 0:00:01.798669 16649 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-13T07:11:49.906834+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-13T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-13T07:11:36.279635+00:00 2021-04-13T07:11:37.974345+00:00 0:00:01.694710 16648 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-13T07:11:33.954600+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-13T06:00:00+00:00 PythonOperator 2021-04-13T07:11:30.428466+00:00 2021-04-13T07:11:33.311201+00:00 0:00:02.882735 16647 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T07:11:27.950123+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-13T06:00:00+00:00 PythonOperator 2021-04-13T07:11:14.175191+00:00 2021-04-13T07:11:17.232668+00:00 0:00:03.057477 16646 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T07:11:11.855231+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-13T06:00:00+00:00 TriggerDagRunOperator 2021-04-13T07:11:08.567489+00:00 2021-04-13T07:11:09.082911+00:00 0:00:00.515422 16645 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T07:11:05.843617+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-13T06:00:00+00:00 TriggerDagRunOperator 2021-04-13T07:11:08.361213+00:00 2021-04-13T07:11:08.795225+00:00 0:00:00.434012 16644 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T07:11:05.843581+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-13T06:05:00+00:00 EmrJobFlowSensor 2021-04-13T07:05:55.611798+00:00 2021-04-13T07:13:58.113103+00:00 0:08:02.501305 16643 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T07:05:53.311112+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-13T06:05:00+00:00 EmrCreateJobFlowOperator 2021-04-13T07:05:33.825603+00:00 2021-04-13T07:05:35.491039+00:00 0:00:01.665436 16642 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-13T07:05:31.286129+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-13T06:05:00+00:00 PythonOperator 2021-04-13T07:05:11.702425+00:00 2021-04-13T07:05:14.400760+00:00 0:00:02.698335 16641 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T07:05:09.285120+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-13T06:00:00+00:00 EmrJobFlowSensor 2021-04-13T07:00:55.257989+00:00 2021-04-13T07:10:58.135081+00:00 0:10:02.877092 16640 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T07:00:52.846527+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-13T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-13T07:00:33.102571+00:00 2021-04-13T07:00:34.778432+00:00 0:00:01.675861 16639 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-13T07:00:30.755771+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-13T06:00:00+00:00 PythonOperator 2021-04-13T07:00:13.023366+00:00 2021-04-13T07:00:15.975954+00:00 0:00:02.952588 16638 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-13T07:00:10.684066+00:00 2 default_pool
success primary-audience-global-ind_v003 create_cluster 2021-04-13T06:16:58.960524+00:00 PythonOperator 2021-04-13T06:17:27.867948+00:00 2021-04-13T06:17:30.941619+00:00 0:00:03.073671 16636 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T06:17:25.668733+00:00 2 default_pool
success primary-audience-global-ind_v003 validation 2021-04-13T06:16:58.960524+00:00 PythonOperator 2021-04-13T06:17:07.905636+00:00 2021-04-13T06:17:08.186407+00:00 0:00:00.280771 16635 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-13T06:17:05.644151+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-13T05:00:00+00:00 EmrJobFlowSensor 2021-04-13T06:11:11.029475+00:00 2021-04-13T06:20:13.703267+00:00 0:09:02.673792 16634 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T06:11:08.792769+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-13T05:00:00+00:00 EmrJobFlowSensor 2021-04-13T06:11:03.159138+00:00 2021-04-13T06:19:05.597511+00:00 0:08:02.438373 16633 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T06:11:00.785727+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-13T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-13T06:10:41.624200+00:00 2021-04-13T06:10:43.285379+00:00 0:00:01.661179 16632 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-13T06:10:38.742148+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-13T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-13T06:10:39.144620+00:00 2021-04-13T06:10:41.289805+00:00 0:00:02.145185 16631 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-13T06:10:36.782445+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-13T05:00:00+00:00 PythonOperator 2021-04-13T06:10:19.013492+00:00 2021-04-13T06:10:21.890501+00:00 0:00:02.877009 16630 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T06:10:16.721859+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-13T05:00:00+00:00 PythonOperator 2021-04-13T06:10:17.252525+00:00 2021-04-13T06:10:20.088849+00:00 0:00:02.836324 16629 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T06:10:14.723917+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-13T05:00:00+00:00 TriggerDagRunOperator 2021-04-13T06:10:05.536196+00:00 2021-04-13T06:10:06.050060+00:00 0:00:00.513864 16628 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T06:10:02.713335+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-13T05:00:00+00:00 TriggerDagRunOperator 2021-04-13T06:10:04.878798+00:00 2021-04-13T06:10:05.259518+00:00 0:00:00.380720 16627 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T06:10:02.713368+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-13T05:05:00+00:00 EmrJobFlowSensor 2021-04-13T06:06:00.853360+00:00 2021-04-13T06:14:03.311171+00:00 0:08:02.457811 16626 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T06:05:58.461308+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-13T05:05:00+00:00 EmrCreateJobFlowOperator 2021-04-13T06:05:40.472426+00:00 2021-04-13T06:05:42.133150+00:00 0:00:01.660724 16625 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-13T06:05:38.317731+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-13T05:05:00+00:00 PythonOperator 2021-04-13T06:05:18.784562+00:00 2021-04-13T06:05:21.481238+00:00 0:00:02.696676 16624 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T06:05:16.345923+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-13T05:00:00+00:00 EmrJobFlowSensor 2021-04-13T06:00:54.334545+00:00 2021-04-13T06:09:57.196330+00:00 0:09:02.861785 16623 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T06:00:51.907950+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-13T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-13T06:00:33.088137+00:00 2021-04-13T06:00:34.766853+00:00 0:00:01.678716 16622 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-13T06:00:29.886204+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-13T05:00:00+00:00 PythonOperator 2021-04-13T06:00:10.403954+00:00 2021-04-13T06:00:13.176974+00:00 0:00:02.773020 16621 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-13T06:00:07.882206+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-13T04:00:00+00:00 EmrJobFlowSensor 2021-04-13T05:12:10.806981+00:00 2021-04-13T05:21:13.339195+00:00 0:09:02.532214 16619 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T05:12:08.601999+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-13T04:00:00+00:00 EmrJobFlowSensor 2021-04-13T05:12:07.043773+00:00 2021-04-13T05:20:09.596689+00:00 0:08:02.552916 16618 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T05:12:04.643377+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-13T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-13T05:11:50.826908+00:00 2021-04-13T05:11:52.533012+00:00 0:00:01.706104 16617 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-13T05:11:48.584753+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-13T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-13T05:11:44.999146+00:00 2021-04-13T05:11:46.788843+00:00 0:00:01.789697 16616 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-13T05:11:42.652381+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-13T04:00:00+00:00 PythonOperator 2021-04-13T05:11:29.057561+00:00 2021-04-13T05:11:32.151127+00:00 0:00:03.093566 16615 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T05:11:26.518119+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-13T04:00:00+00:00 PythonOperator 2021-04-13T05:11:24.745436+00:00 2021-04-13T05:11:27.742883+00:00 0:00:02.997447 16614 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T05:11:22.520642+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-13T04:00:00+00:00 TriggerDagRunOperator 2021-04-13T05:11:05.842632+00:00 2021-04-13T05:11:06.370871+00:00 0:00:00.528239 16613 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T05:11:02.507264+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-13T04:00:00+00:00 TriggerDagRunOperator 2021-04-13T05:11:05.753299+00:00 2021-04-13T05:11:06.156505+00:00 0:00:00.403206 16612 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T05:11:02.507303+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-13T04:05:00+00:00 EmrJobFlowSensor 2021-04-13T05:06:04.604619+00:00 2021-04-13T05:14:07.223743+00:00 0:08:02.619124 16611 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T05:06:02.071287+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-13T04:05:00+00:00 EmrCreateJobFlowOperator 2021-04-13T05:05:42.179506+00:00 2021-04-13T05:05:43.798863+00:00 0:00:01.619357 16610 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-13T05:05:40.059723+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-13T04:05:00+00:00 PythonOperator 2021-04-13T05:05:22.166270+00:00 2021-04-13T05:05:24.852659+00:00 0:00:02.686389 16609 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T05:05:19.982773+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-13T04:00:00+00:00 EmrJobFlowSensor 2021-04-13T05:00:48.811413+00:00 2021-04-13T05:10:51.704575+00:00 0:10:02.893162 16608 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T05:00:45.625119+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-13T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-13T05:00:25.890453+00:00 2021-04-13T05:00:27.900097+00:00 0:00:02.009644 16607 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-13T05:00:23.620169+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-13T04:00:00+00:00 PythonOperator 2021-04-13T05:00:04.822655+00:00 2021-04-13T05:00:07.860384+00:00 0:00:03.037729 16606 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-13T05:00:01.650463+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-13T03:00:00+00:00 EmrJobFlowSensor 2021-04-13T04:11:26.037069+00:00 2021-04-13T04:20:28.725944+00:00 0:09:02.688875 16604 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T04:11:23.642221+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-13T03:00:00+00:00 EmrJobFlowSensor 2021-04-13T04:11:21.729038+00:00 2021-04-13T04:20:24.546245+00:00 0:09:02.817207 16603 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T04:11:19.498955+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-13T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-13T04:11:04.206823+00:00 2021-04-13T04:11:05.966185+00:00 0:00:01.759362 16602 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-13T04:11:01.487875+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-13T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-13T04:11:01.621585+00:00 2021-04-13T04:11:03.715862+00:00 0:00:02.094277 16601 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-13T04:10:59.481649+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-13T03:00:00+00:00 PythonOperator 2021-04-13T04:10:42.374202+00:00 2021-04-13T04:10:45.324679+00:00 0:00:02.950477 16600 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T04:10:39.460469+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-13T03:00:00+00:00 PythonOperator 2021-04-13T04:10:40.294648+00:00 2021-04-13T04:10:43.383274+00:00 0:00:03.088626 16599 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T04:10:37.457303+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-13T03:00:00+00:00 TriggerDagRunOperator 2021-04-13T04:10:24.331862+00:00 2021-04-13T04:10:24.898049+00:00 0:00:00.566187 16598 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T04:10:21.487875+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-13T03:00:00+00:00 TriggerDagRunOperator 2021-04-13T04:10:23.872058+00:00 2021-04-13T04:10:24.417510+00:00 0:00:00.545452 16597 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T04:10:21.487835+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-13T03:05:00+00:00 EmrJobFlowSensor 2021-04-13T04:06:03.228704+00:00 2021-04-13T04:15:05.992416+00:00 0:09:02.763712 16596 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T04:06:00.884608+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-13T03:05:00+00:00 EmrCreateJobFlowOperator 2021-04-13T04:05:41.090515+00:00 2021-04-13T04:05:42.729018+00:00 0:00:01.638503 16595 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-13T04:05:38.871388+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-13T03:05:00+00:00 PythonOperator 2021-04-13T04:05:19.025067+00:00 2021-04-13T04:05:21.687847+00:00 0:00:02.662780 16594 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T04:05:16.800204+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-13T03:00:00+00:00 EmrJobFlowSensor 2021-04-13T04:01:01.135454+00:00 2021-04-13T04:10:04.006763+00:00 0:09:02.871309 16593 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T04:00:58.641291+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-13T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-13T04:00:40.651965+00:00 2021-04-13T04:00:42.353699+00:00 0:00:01.701734 16592 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-13T04:00:38.429945+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-13T03:00:00+00:00 PythonOperator 2021-04-13T04:00:19.387546+00:00 2021-04-13T04:00:22.233159+00:00 0:00:02.845613 16591 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-13T04:00:16.472355+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-13T02:00:00+00:00 EmrJobFlowSensor 2021-04-13T03:11:29.396242+00:00 2021-04-13T03:21:32.218841+00:00 0:10:02.822599 16589 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T03:11:26.840681+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-13T02:00:00+00:00 EmrJobFlowSensor 2021-04-13T03:11:23.191916+00:00 2021-04-13T03:20:26.072748+00:00 0:09:02.880832 16588 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T03:11:20.837876+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-13T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-13T03:11:07.235095+00:00 2021-04-13T03:11:08.998781+00:00 0:00:01.763686 16587 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-13T03:11:04.867057+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-13T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-13T03:11:01.050338+00:00 2021-04-13T03:11:02.738121+00:00 0:00:01.687783 16586 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-13T03:10:58.843858+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-13T02:00:00+00:00 PythonOperator 2021-04-13T03:10:47.210868+00:00 2021-04-13T03:10:50.313618+00:00 0:00:03.102750 16585 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T03:10:44.855528+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-13T02:00:00+00:00 PythonOperator 2021-04-13T03:10:39.127391+00:00 2021-04-13T03:10:41.893249+00:00 0:00:02.765858 16584 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T03:10:36.806431+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-13T02:00:00+00:00 TriggerDagRunOperator 2021-04-13T03:10:21.751954+00:00 2021-04-13T03:10:22.263757+00:00 0:00:00.511803 16583 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T03:10:18.797270+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-13T02:00:00+00:00 TriggerDagRunOperator 2021-04-13T03:10:21.191713+00:00 2021-04-13T03:10:21.611076+00:00 0:00:00.419363 16582 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T03:10:18.797217+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-13T02:05:00+00:00 EmrJobFlowSensor 2021-04-13T03:06:02.568614+00:00 2021-04-13T03:15:05.213580+00:00 0:09:02.644966 16581 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T03:06:00.359638+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-13T02:05:00+00:00 EmrCreateJobFlowOperator 2021-04-13T03:05:40.401017+00:00 2021-04-13T03:05:42.490844+00:00 0:00:02.089827 16580 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-13T03:05:38.270748+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-13T02:05:00+00:00 PythonOperator 2021-04-13T03:05:18.669133+00:00 2021-04-13T03:05:21.433075+00:00 0:00:02.763942 16579 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T03:05:16.225854+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-13T02:00:00+00:00 EmrJobFlowSensor 2021-04-13T03:00:54.103114+00:00 2021-04-13T03:09:56.890310+00:00 0:09:02.787196 16578 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T03:00:51.730627+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-13T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-13T03:00:32.215650+00:00 2021-04-13T03:00:33.960083+00:00 0:00:01.744433 16577 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-13T03:00:29.772432+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-13T02:00:00+00:00 PythonOperator 2021-04-13T03:00:10.028554+00:00 2021-04-13T03:00:12.928620+00:00 0:00:02.900066 16576 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-13T03:00:07.689112+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-13T01:00:00+00:00 EmrJobFlowSensor 2021-04-13T02:21:45.939271+00:00 2021-04-13T02:31:48.776243+00:00 0:10:02.836972 16575 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T02:21:43.546541+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-13T01:00:00+00:00 EmrJobFlowSensor 2021-04-13T02:21:41.673025+00:00 2021-04-13T02:38:45.435862+00:00 0:17:03.762837 16574 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T02:21:39.489316+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-13T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-13T02:21:26.106089+00:00 2021-04-13T02:21:27.792101+00:00 0:00:01.686012 16573 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-13T02:21:23.411872+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-13T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-13T02:21:19.842850+00:00 2021-04-13T02:21:21.643428+00:00 0:00:01.800578 16572 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-13T02:21:17.409344+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-13T01:00:00+00:00 PythonOperator 2021-04-13T02:21:03.681664+00:00 2021-04-13T02:21:06.627575+00:00 0:00:02.945911 16571 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T02:21:01.385011+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-13T01:00:00+00:00 PythonOperator 2021-04-13T02:20:59.782098+00:00 2021-04-13T02:21:02.671515+00:00 0:00:02.889417 16570 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T02:20:57.391822+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-13T01:00:00+00:00 TriggerDagRunOperator 2021-04-13T02:20:43.894400+00:00 2021-04-13T02:20:44.362854+00:00 0:00:00.468454 16569 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T02:20:41.320839+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-13T01:00:00+00:00 TriggerDagRunOperator 2021-04-13T02:20:43.814956+00:00 2021-04-13T02:20:44.377999+00:00 0:00:00.563043 16568 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T02:20:41.320868+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-13T01:05:00+00:00 EmrJobFlowSensor 2021-04-13T02:05:56.451432+00:00 2021-04-13T02:14:59.084846+00:00 0:09:02.633414 16566 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T02:05:53.977885+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-13T01:05:00+00:00 EmrCreateJobFlowOperator 2021-04-13T02:05:36.298462+00:00 2021-04-13T02:05:38.266510+00:00 0:00:01.968048 16565 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-13T02:05:33.961855+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-13T01:05:00+00:00 PythonOperator 2021-04-13T02:05:13.990676+00:00 2021-04-13T02:05:16.691105+00:00 0:00:02.700429 16564 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T02:05:11.846743+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-13T01:00:00+00:00 EmrJobFlowSensor 2021-04-13T02:00:53.645445+00:00 2021-04-13T02:08:56.237354+00:00 0:08:02.591909 16563 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T02:00:51.435659+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-13T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-13T02:00:33.789604+00:00 2021-04-13T02:00:35.656030+00:00 0:00:01.866426 16562 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-13T02:00:31.415370+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-13T01:00:00+00:00 PythonOperator 2021-04-13T02:00:09.993309+00:00 2021-04-13T02:00:12.778363+00:00 0:00:02.785054 16561 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-13T02:00:07.450542+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-13T00:00:00+00:00 EmrJobFlowSensor 2021-04-13T01:11:15.005704+00:00 2021-04-13T01:20:17.690535+00:00 0:09:02.684831 16560 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T01:11:12.752447+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-13T00:00:00+00:00 EmrJobFlowSensor 2021-04-13T01:11:06.971789+00:00 2021-04-13T01:20:09.789085+00:00 0:09:02.817296 16559 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T01:11:04.742743+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-13T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-13T01:10:53.187754+00:00 2021-04-13T01:10:55.051712+00:00 0:00:01.863958 16558 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-13T01:10:50.729643+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-13T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-13T01:10:45.565638+00:00 2021-04-13T01:10:47.554479+00:00 0:00:01.988841 16557 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-13T01:10:42.785244+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-13T00:00:00+00:00 PythonOperator 2021-04-13T01:10:31.210938+00:00 2021-04-13T01:10:34.724875+00:00 0:00:03.513937 16556 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T01:10:28.777133+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-13T00:00:00+00:00 PythonOperator 2021-04-13T01:10:22.956203+00:00 2021-04-13T01:10:25.721923+00:00 0:00:02.765720 16555 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T01:10:20.745427+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-13T00:00:00+00:00 TriggerDagRunOperator 2021-04-13T01:10:17.317853+00:00 2021-04-13T01:10:18.458169+00:00 0:00:01.140316 16554 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T01:10:14.699694+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-13T00:00:00+00:00 TriggerDagRunOperator 2021-04-13T01:10:17.113438+00:00 2021-04-13T01:10:18.171106+00:00 0:00:01.057668 16553 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T01:10:14.699722+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-13T00:05:00+00:00 EmrJobFlowSensor 2021-04-13T01:05:54.977306+00:00 2021-04-13T01:14:57.583633+00:00 0:09:02.606327 16551 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T01:05:52.708545+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-13T00:05:00+00:00 EmrCreateJobFlowOperator 2021-04-13T01:05:33.307842+00:00 2021-04-13T01:05:35.029976+00:00 0:00:01.722134 16550 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-13T01:05:30.754804+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-13T00:05:00+00:00 PythonOperator 2021-04-13T01:05:10.987995+00:00 2021-04-13T01:05:13.790052+00:00 0:00:02.802057 16549 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T01:05:08.741230+00:00 2 default_pool