Task Instances

  State Dag Id Task Id Execution Date Operator Start Date End Date Duration Job Id Hostname Unixname Priority Weight Queue Queued Dttm Try Number Pool Log Url
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-18T19:00:00+00:00 TriggerDagRunOperator 2021-04-18T20:11:15.866206+00:00 2021-04-18T20:11:16.392301+00:00 0:00:00.526095 18658 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T20:11:13.495319+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-18T19:00:00+00:00 TriggerDagRunOperator 2021-04-18T20:11:15.785180+00:00 2021-04-18T20:11:16.191013+00:00 0:00:00.405833 18657 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T20:11:13.495350+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-18T19:05:00+00:00 EmrJobFlowSensor 2021-04-18T20:05:46.735729+00:00 2021-04-18T20:14:49.305188+00:00 0:09:02.569459 18656 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T20:05:44.595453+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-18T19:05:00+00:00 EmrCreateJobFlowOperator 2021-04-18T20:05:26.692679+00:00 2021-04-18T20:05:28.358180+00:00 0:00:01.665501 18655 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-18T20:05:24.548276+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-18T19:05:00+00:00 PythonOperator 2021-04-18T20:05:04.878044+00:00 2021-04-18T20:05:07.956749+00:00 0:00:03.078705 18654 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-18T20:05:02.503330+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-18T19:00:00+00:00 EmrJobFlowSensor 2021-04-18T20:01:00.742823+00:00 2021-04-18T20:11:03.658844+00:00 0:10:02.916021 18653 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-18T20:00:58.267754+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-18T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-18T20:00:38.669151+00:00 2021-04-18T20:00:40.467771+00:00 0:00:01.798620 18652 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-18T20:00:36.139266+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-18T19:00:00+00:00 PythonOperator 2021-04-18T20:00:16.675826+00:00 2021-04-18T20:00:19.705674+00:00 0:00:03.029848 18651 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-18T20:00:14.145313+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-18T18:00:00+00:00 EmrJobFlowSensor 2021-04-18T19:12:19.481361+00:00 2021-04-18T19:22:22.184673+00:00 0:10:02.703312 18649 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T19:12:17.240603+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-18T18:00:00+00:00 EmrJobFlowSensor 2021-04-18T19:12:09.525585+00:00 2021-04-18T19:21:12.186928+00:00 0:09:02.661343 18648 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T19:12:07.230306+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-18T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-18T19:11:59.803698+00:00 2021-04-18T19:12:01.508055+00:00 0:00:01.704357 18647 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-18T19:11:57.222216+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-18T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-18T19:11:47.433431+00:00 2021-04-18T19:11:49.142222+00:00 0:00:01.708791 18646 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-18T19:11:45.221793+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-18T18:00:00+00:00 PythonOperator 2021-04-18T19:11:38.020516+00:00 2021-04-18T19:11:41.092972+00:00 0:00:03.072456 18645 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-18T19:11:35.247653+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-18T18:00:00+00:00 PythonOperator 2021-04-18T19:11:25.483738+00:00 2021-04-18T19:11:28.415264+00:00 0:00:02.931526 18644 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-18T19:11:23.198357+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-18T18:00:00+00:00 TriggerDagRunOperator 2021-04-18T19:11:19.523625+00:00 2021-04-18T19:11:20.075386+00:00 0:00:00.551761 18643 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T19:11:17.194640+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-18T18:00:00+00:00 TriggerDagRunOperator 2021-04-18T19:11:19.403333+00:00 2021-04-18T19:11:19.835081+00:00 0:00:00.431748 18642 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T19:11:17.194687+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-18T18:05:00+00:00 EmrJobFlowSensor 2021-04-18T19:06:02.964248+00:00 2021-04-18T19:15:05.625977+00:00 0:09:02.661729 18641 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T19:06:00.758350+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-18T18:05:00+00:00 EmrCreateJobFlowOperator 2021-04-18T19:05:40.942043+00:00 2021-04-18T19:05:42.579504+00:00 0:00:01.637461 18640 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-18T19:05:38.706579+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-18T18:05:00+00:00 PythonOperator 2021-04-18T19:05:18.965449+00:00 2021-04-18T19:05:22.024544+00:00 0:00:03.059095 18639 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-18T19:05:16.686992+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-18T18:00:00+00:00 EmrJobFlowSensor 2021-04-18T19:01:00.815662+00:00 2021-04-18T19:11:03.776733+00:00 0:10:02.961071 18638 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-18T19:00:58.258886+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-18T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-18T19:00:40.409564+00:00 2021-04-18T19:00:42.179784+00:00 0:00:01.770220 18637 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-18T19:00:38.108214+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-18T18:00:00+00:00 PythonOperator 2021-04-18T19:00:18.530959+00:00 2021-04-18T19:00:21.523691+00:00 0:00:02.992732 18636 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-18T19:00:16.098944+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-18T17:00:00+00:00 EmrJobFlowSensor 2021-04-18T18:10:09.337468+00:00 2021-04-18T18:19:12.012206+00:00 0:09:02.674738 18634 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T18:10:07.145997+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-18T17:00:00+00:00 EmrJobFlowSensor 2021-04-18T18:09:55.349443+00:00 2021-04-18T18:19:58.140470+00:00 0:10:02.791027 18633 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T18:09:53.123168+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-18T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-18T18:09:47.356764+00:00 2021-04-18T18:09:49.078742+00:00 0:00:01.721978 18632 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-18T18:09:45.128047+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-18T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-18T18:09:33.554434+00:00 2021-04-18T18:09:35.376896+00:00 0:00:01.822462 18631 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-18T18:09:31.155329+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-18T17:00:00+00:00 PythonOperator 2021-04-18T18:09:25.525916+00:00 2021-04-18T18:09:28.682861+00:00 0:00:03.156945 18630 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-18T18:09:23.168527+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-18T17:00:00+00:00 PythonOperator 2021-04-18T18:09:12.135531+00:00 2021-04-18T18:09:15.565852+00:00 0:00:03.430321 18629 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-18T18:09:09.152766+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-18T17:00:00+00:00 TriggerDagRunOperator 2021-04-18T18:09:03.702221+00:00 2021-04-18T18:09:04.207565+00:00 0:00:00.505344 18628 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T18:09:01.148243+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-18T17:00:00+00:00 TriggerDagRunOperator 2021-04-18T18:09:03.402766+00:00 2021-04-18T18:09:03.844123+00:00 0:00:00.441357 18627 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T18:09:01.148192+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-18T17:05:00+00:00 EmrJobFlowSensor 2021-04-18T18:06:03.400307+00:00 2021-04-18T18:15:05.971397+00:00 0:09:02.571090 18626 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T18:06:00.843491+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-18T17:05:00+00:00 EmrCreateJobFlowOperator 2021-04-18T18:05:40.840179+00:00 2021-04-18T18:05:42.529139+00:00 0:00:01.688960 18625 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-18T18:05:38.744057+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-18T17:05:00+00:00 PythonOperator 2021-04-18T18:05:19.184584+00:00 2021-04-18T18:05:22.041376+00:00 0:00:02.856792 18624 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-18T18:05:16.762123+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-18T17:00:00+00:00 EmrJobFlowSensor 2021-04-18T18:00:48.972803+00:00 2021-04-18T18:08:51.550663+00:00 0:08:02.577860 18623 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-18T18:00:46.195357+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-18T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-18T18:00:26.322745+00:00 2021-04-18T18:00:28.014906+00:00 0:00:01.692161 18622 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-18T18:00:24.157648+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-18T17:00:00+00:00 PythonOperator 2021-04-18T18:00:06.691923+00:00 2021-04-18T18:00:10.243573+00:00 0:00:03.551650 18621 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-18T18:00:04.141094+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-18T16:00:00+00:00 EmrJobFlowSensor 2021-04-18T17:11:20.370263+00:00 2021-04-18T17:21:23.246721+00:00 0:10:02.876458 18619 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T17:11:18.144991+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-18T16:00:00+00:00 EmrJobFlowSensor 2021-04-18T17:11:08.708907+00:00 2021-04-18T17:19:11.182756+00:00 0:08:02.473849 18618 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T17:11:06.125435+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-18T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-18T17:11:00.580897+00:00 2021-04-18T17:11:02.345267+00:00 0:00:01.764370 18617 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-18T17:10:58.071663+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-18T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-18T17:10:46.807790+00:00 2021-04-18T17:10:48.587468+00:00 0:00:01.779678 18616 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-18T17:10:43.917643+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-18T16:00:00+00:00 PythonOperator 2021-04-18T17:10:38.336733+00:00 2021-04-18T17:10:41.498796+00:00 0:00:03.162063 18615 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-18T17:10:35.871690+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-18T16:00:00+00:00 PythonOperator 2021-04-18T17:10:26.039088+00:00 2021-04-18T17:10:28.939148+00:00 0:00:02.900060 18614 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-18T17:10:23.862188+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-18T16:00:00+00:00 TriggerDagRunOperator 2021-04-18T17:10:20.621258+00:00 2021-04-18T17:10:21.135643+00:00 0:00:00.514385 18613 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T17:10:17.859893+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-18T16:00:00+00:00 TriggerDagRunOperator 2021-04-18T17:10:20.501334+00:00 2021-04-18T17:10:20.922814+00:00 0:00:00.421480 18612 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T17:10:17.859860+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-18T16:05:00+00:00 EmrJobFlowSensor 2021-04-18T17:05:47.487142+00:00 2021-04-18T17:14:50.053307+00:00 0:09:02.566165 18611 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T17:05:45.401674+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-18T16:05:00+00:00 EmrCreateJobFlowOperator 2021-04-18T17:05:25.766703+00:00 2021-04-18T17:05:27.410789+00:00 0:00:01.644086 18610 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-18T17:05:23.452431+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-18T16:05:00+00:00 PythonOperator 2021-04-18T17:05:03.772208+00:00 2021-04-18T17:05:07.508978+00:00 0:00:03.736770 18609 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-18T17:05:01.372516+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-18T16:00:00+00:00 EmrJobFlowSensor 2021-04-18T17:01:01.422554+00:00 2021-04-18T17:10:04.136427+00:00 0:09:02.713873 18608 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-18T17:00:59.040786+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-18T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-18T17:00:39.729984+00:00 2021-04-18T17:00:41.520050+00:00 0:00:01.790066 18607 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-18T17:00:36.798245+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-18T16:00:00+00:00 PythonOperator 2021-04-18T17:00:17.060840+00:00 2021-04-18T17:00:20.958115+00:00 0:00:03.897275 18606 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-18T17:00:14.773643+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-18T15:00:00+00:00 EmrJobFlowSensor 2021-04-18T16:12:10.701302+00:00 2021-04-18T16:22:13.411246+00:00 0:10:02.709944 18604 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T16:12:08.444285+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-18T15:00:00+00:00 EmrJobFlowSensor 2021-04-18T16:12:08.813941+00:00 2021-04-18T16:22:11.564433+00:00 0:10:02.750492 18603 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T16:12:06.360677+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-18T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-18T16:11:48.973087+00:00 2021-04-18T16:11:50.656198+00:00 0:00:01.683111 18602 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-18T16:11:46.315627+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-18T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-18T16:11:46.532515+00:00 2021-04-18T16:11:48.654615+00:00 0:00:02.122100 18601 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-18T16:11:44.315934+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-18T15:00:00+00:00 PythonOperator 2021-04-18T16:11:26.771800+00:00 2021-04-18T16:11:29.739090+00:00 0:00:02.967290 18600 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-18T16:11:24.362286+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-18T15:00:00+00:00 PythonOperator 2021-04-18T16:11:24.525844+00:00 2021-04-18T16:11:27.729232+00:00 0:00:03.203388 18599 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-18T16:11:22.297766+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-18T15:00:00+00:00 TriggerDagRunOperator 2021-04-18T16:11:08.959913+00:00 2021-04-18T16:11:09.484092+00:00 0:00:00.524179 18598 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T16:11:06.349117+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-18T15:00:00+00:00 TriggerDagRunOperator 2021-04-18T16:11:08.785593+00:00 2021-04-18T16:11:09.216978+00:00 0:00:00.431385 18597 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T16:11:06.349060+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-18T15:05:00+00:00 EmrJobFlowSensor 2021-04-18T16:05:56.061155+00:00 2021-04-18T16:14:58.593973+00:00 0:09:02.532818 18596 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T16:05:53.807309+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-18T15:05:00+00:00 EmrCreateJobFlowOperator 2021-04-18T16:05:33.961195+00:00 2021-04-18T16:05:35.570190+00:00 0:00:01.608995 18595 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-18T16:05:31.785707+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-18T15:05:00+00:00 PythonOperator 2021-04-18T16:05:11.902084+00:00 2021-04-18T16:05:14.986958+00:00 0:00:03.084874 18594 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-18T16:05:09.707112+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-18T15:00:00+00:00 EmrJobFlowSensor 2021-04-18T16:00:55.448375+00:00 2021-04-18T16:10:58.317007+00:00 0:10:02.868632 18593 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-18T16:00:53.195454+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-18T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-18T16:00:33.466729+00:00 2021-04-18T16:00:35.415999+00:00 0:00:01.949270 18592 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-18T16:00:31.146612+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-18T15:00:00+00:00 PythonOperator 2021-04-18T16:00:11.464075+00:00 2021-04-18T16:00:14.396048+00:00 0:00:02.931973 18591 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-18T16:00:09.126788+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-18T14:00:00+00:00 EmrJobFlowSensor 2021-04-18T15:12:40.020453+00:00 2021-04-18T15:22:42.818974+00:00 0:10:02.798521 18589 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T15:12:37.736439+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-18T14:00:00+00:00 EmrJobFlowSensor 2021-04-18T15:12:25.996371+00:00 2021-04-18T15:23:28.956757+00:00 0:11:02.960386 18588 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T15:12:23.725344+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-18T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-18T15:12:19.897756+00:00 2021-04-18T15:12:21.571063+00:00 0:00:01.673307 18587 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-18T15:12:17.717330+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-18T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-18T15:12:04.107641+00:00 2021-04-18T15:12:05.952022+00:00 0:00:01.844381 18586 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-18T15:12:01.704452+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-18T14:00:00+00:00 PythonOperator 2021-04-18T15:11:58.462963+00:00 2021-04-18T15:12:01.409209+00:00 0:00:02.946246 18585 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-18T15:11:55.705627+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-18T14:00:00+00:00 PythonOperator 2021-04-18T15:11:40.247345+00:00 2021-04-18T15:11:43.714638+00:00 0:00:03.467293 18584 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-18T15:11:37.781527+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-18T14:00:00+00:00 TriggerDagRunOperator 2021-04-18T15:11:32.769316+00:00 2021-04-18T15:11:33.294297+00:00 0:00:00.524981 18583 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T15:11:29.759687+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-18T14:00:00+00:00 TriggerDagRunOperator 2021-04-18T15:11:32.395684+00:00 2021-04-18T15:11:32.838282+00:00 0:00:00.442598 18582 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T15:11:29.759726+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-18T14:05:00+00:00 EmrJobFlowSensor 2021-04-18T15:05:53.872958+00:00 2021-04-18T15:14:56.392090+00:00 0:09:02.519132 18581 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T15:05:51.367507+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-18T14:05:00+00:00 EmrCreateJobFlowOperator 2021-04-18T15:05:31.602661+00:00 2021-04-18T15:05:33.352258+00:00 0:00:01.749597 18580 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-18T15:05:29.287056+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-18T14:05:00+00:00 PythonOperator 2021-04-18T15:05:09.375404+00:00 2021-04-18T15:05:12.242759+00:00 0:00:02.867355 18579 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-18T15:05:07.221266+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-18T14:00:00+00:00 EmrJobFlowSensor 2021-04-18T15:01:03.052488+00:00 2021-04-18T15:11:05.834670+00:00 0:10:02.782182 18578 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-18T15:01:00.786806+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-18T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-18T15:00:38.980439+00:00 2021-04-18T15:00:40.655148+00:00 0:00:01.674709 18577 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-18T15:00:36.737773+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-18T14:00:00+00:00 PythonOperator 2021-04-18T15:00:09.718450+00:00 2021-04-18T15:00:12.923256+00:00 0:00:03.204806 18576 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-18T15:00:06.758455+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-18T13:00:00+00:00 EmrJobFlowSensor 2021-04-18T14:12:28.977043+00:00 2021-04-18T14:22:31.694558+00:00 0:10:02.717515 18574 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T14:12:26.732178+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-18T13:00:00+00:00 EmrJobFlowSensor 2021-04-18T14:12:17.137286+00:00 2021-04-18T14:23:20.180645+00:00 0:11:03.043359 18573 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T14:12:14.718984+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-18T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-18T14:12:04.994202+00:00 2021-04-18T14:12:06.778604+00:00 0:00:01.784402 18572 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-18T14:12:02.708159+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-18T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-18T14:11:55.132912+00:00 2021-04-18T14:11:56.895771+00:00 0:00:01.762859 18571 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-18T14:11:52.769314+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-18T13:00:00+00:00 PythonOperator 2021-04-18T14:11:40.917991+00:00 2021-04-18T14:11:44.360477+00:00 0:00:03.442486 18570 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-18T14:11:38.696390+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-18T13:00:00+00:00 PythonOperator 2021-04-18T14:11:33.077043+00:00 2021-04-18T14:11:36.026972+00:00 0:00:02.949929 18569 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-18T14:11:30.685605+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-18T13:00:00+00:00 TriggerDagRunOperator 2021-04-18T14:11:16.959102+00:00 2021-04-18T14:11:17.477879+00:00 0:00:00.518777 18568 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T14:11:14.628884+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-18T13:00:00+00:00 TriggerDagRunOperator 2021-04-18T14:11:16.827440+00:00 2021-04-18T14:11:17.289635+00:00 0:00:00.462195 18567 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T14:11:14.628918+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-18T13:05:00+00:00 EmrJobFlowSensor 2021-04-18T14:06:06.860626+00:00 2021-04-18T14:15:09.601005+00:00 0:09:02.740379 18566 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T14:06:04.109232+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-18T13:05:00+00:00 EmrCreateJobFlowOperator 2021-04-18T14:05:44.421347+00:00 2021-04-18T14:05:46.075161+00:00 0:00:01.653814 18565 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-18T14:05:42.095403+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-18T13:05:00+00:00 PythonOperator 2021-04-18T14:05:24.572495+00:00 2021-04-18T14:05:27.467372+00:00 0:00:02.894877 18564 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-18T14:05:22.031351+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-18T13:00:00+00:00 EmrJobFlowSensor 2021-04-18T14:00:53.994042+00:00 2021-04-18T14:10:56.670875+00:00 0:10:02.676833 18563 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-18T14:00:51.695711+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-18T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-18T14:00:34.183040+00:00 2021-04-18T14:00:36.062126+00:00 0:00:01.879086 18562 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-18T14:00:31.677112+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-18T13:00:00+00:00 PythonOperator 2021-04-18T14:00:11.827080+00:00 2021-04-18T14:00:15.047590+00:00 0:00:03.220510 18561 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-18T14:00:09.615942+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-18T12:00:00+00:00 EmrJobFlowSensor 2021-04-18T13:16:12.004634+00:00 2021-04-18T13:25:14.710528+00:00 0:09:02.705894 18560 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T13:16:09.589257+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-18T12:00:00+00:00 EmrJobFlowSensor 2021-04-18T13:16:00.143553+00:00 2021-04-18T13:25:02.967873+00:00 0:09:02.824320 18559 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T13:15:57.566724+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-18T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-18T13:15:49.917893+00:00 2021-04-18T13:15:51.597794+00:00 0:00:01.679901 18558 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-18T13:15:47.540818+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-18T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-18T13:15:39.978638+00:00 2021-04-18T13:15:41.683987+00:00 0:00:01.705349 18557 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-18T13:15:37.576557+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-18T12:00:00+00:00 PythonOperator 2021-04-18T13:15:30.288140+00:00 2021-04-18T13:15:33.748134+00:00 0:00:03.459994 18556 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-18T13:15:27.547359+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-18T12:00:00+00:00 PythonOperator 2021-04-18T13:15:17.744056+00:00 2021-04-18T13:15:20.672165+00:00 0:00:02.928109 18555 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-18T13:15:15.477684+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-18T12:00:00+00:00 TriggerDagRunOperator 2021-04-18T13:15:10.013607+00:00 2021-04-18T13:15:10.527834+00:00 0:00:00.514227 18554 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T13:15:07.478420+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-18T12:00:00+00:00 TriggerDagRunOperator 2021-04-18T13:15:09.882575+00:00 2021-04-18T13:15:10.295084+00:00 0:00:00.412509 18553 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T13:15:07.478376+00:00 2 default_pool