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-history-job_v002 create_emr_steps 2021-05-06T16:00:00+00:00 PythonOperator 2021-05-06T17:10:12.298070+00:00 2021-05-06T17:10:15.364889+00:00 0:00:03.066819 25165 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T17:10:10.000893+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-06T16:00:00+00:00 TriggerDagRunOperator 2021-05-06T17:10:06.364151+00:00 2021-05-06T17:10:06.872777+00:00 0:00:00.508626 25164 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T17:10:03.993611+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-06T16:00:00+00:00 TriggerDagRunOperator 2021-05-06T17:10:06.174611+00:00 2021-05-06T17:10:06.591734+00:00 0:00:00.417123 25163 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T17:10:03.993577+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-06T16:05:00+00:00 EmrJobFlowSensor 2021-05-06T17:06:05.989322+00:00 2021-05-06T17:15:08.703819+00:00 0:09:02.714497 25162 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T17:06:03.597052+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-06T16:05:00+00:00 EmrCreateJobFlowOperator 2021-05-06T17:05:45.790032+00:00 2021-05-06T17:05:47.563548+00:00 0:00:01.773516 25161 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-06T17:05:43.543224+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-06T16:05:00+00:00 PythonOperator 2021-05-06T17:05:23.645947+00:00 2021-05-06T17:05:26.736242+00:00 0:00:03.090295 25160 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T17:05:21.518411+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-06T16:00:00+00:00 EmrJobFlowSensor 2021-05-06T17:00:49.406597+00:00 2021-05-06T17:09:52.084166+00:00 0:09:02.677569 25159 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T17:00:47.152576+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-06T16:00:00+00:00 EmrCreateJobFlowOperator 2021-05-06T17:00:27.421635+00:00 2021-05-06T17:00:29.247688+00:00 0:00:01.826053 25158 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-06T17:00:25.076347+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-06T16:00:00+00:00 PythonOperator 2021-05-06T17:00:07.204501+00:00 2021-05-06T17:00:10.347496+00:00 0:00:03.142995 25157 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-06T17:00:05.024184+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-06T15:00:00+00:00 EmrJobFlowSensor 2021-05-06T16:14:26.611583+00:00 2021-05-06T16:23:29.235886+00:00 0:09:02.624303 25156 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T16:14:24.400116+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-06T15:00:00+00:00 EmrJobFlowSensor 2021-05-06T16:14:18.821604+00:00 2021-05-06T16:22:21.329214+00:00 0:08:02.507610 25155 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T16:14:16.459461+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-06T15:00:00+00:00 EmrCreateJobFlowOperator 2021-05-06T16:14:04.889194+00:00 2021-05-06T16:14:06.620985+00:00 0:00:01.731791 25154 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-06T16:14:02.385212+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-06T15:05:00+00:00 EmrJobFlowSensor 2021-05-06T16:13:56.712152+00:00 2021-05-06T16:21:59.315054+00:00 0:08:02.602902 25153 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T16:13:54.333984+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-06T15:00:00+00:00 EmrCreateJobFlowOperator 2021-05-06T16:13:56.679381+00:00 2021-05-06T16:13:58.399604+00:00 0:00:01.720223 25152 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-06T16:13:54.333955+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-06T15:00:00+00:00 PythonOperator 2021-05-06T16:13:42.907806+00:00 2021-05-06T16:13:46.166700+00:00 0:00:03.258894 25151 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T16:13:40.318204+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-06T15:00:00+00:00 PythonOperator 2021-05-06T16:13:36.771066+00:00 2021-05-06T16:13:39.797293+00:00 0:00:03.026227 25150 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T16:13:34.312216+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-06T15:05:00+00:00 EmrCreateJobFlowOperator 2021-05-06T16:13:34.368134+00:00 2021-05-06T16:13:36.393322+00:00 0:00:02.025188 25149 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-06T16:13:32.316551+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-06T15:00:00+00:00 TriggerDagRunOperator 2021-05-06T16:13:22.953156+00:00 2021-05-06T16:13:23.474651+00:00 0:00:00.521495 25148 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T16:13:20.300307+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-06T15:00:00+00:00 TriggerDagRunOperator 2021-05-06T16:13:22.459353+00:00 2021-05-06T16:13:22.828008+00:00 0:00:00.368655 25147 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T16:13:20.300339+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-06T15:05:00+00:00 PythonOperator 2021-05-06T16:13:14.910000+00:00 2021-05-06T16:13:17.925679+00:00 0:00:03.015679 25146 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T16:13:12.291916+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-06T15:00:00+00:00 EmrJobFlowSensor 2021-05-06T16:00:51.947618+00:00 2021-05-06T16:10:54.793059+00:00 0:10:02.845441 25144 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T16:00:49.598219+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-06T15:00:00+00:00 EmrCreateJobFlowOperator 2021-05-06T16:00:32.044518+00:00 2021-05-06T16:00:33.748512+00:00 0:00:01.703994 25143 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-06T16:00:29.747162+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-06T15:00:00+00:00 PythonOperator 2021-05-06T16:00:09.925834+00:00 2021-05-06T16:00:12.977914+00:00 0:00:03.052080 25142 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-06T16:00:07.529762+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-06T14:00:00+00:00 EmrJobFlowSensor 2021-05-06T15:15:24.997560+00:00 2021-05-06T15:27:28.039328+00:00 0:12:03.041768 25141 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T15:15:22.683873+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-06T14:00:00+00:00 EmrJobFlowSensor 2021-05-06T15:15:15.078013+00:00 2021-05-06T15:25:17.849638+00:00 0:10:02.771625 25140 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T15:15:12.661324+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-06T14:00:00+00:00 EmrCreateJobFlowOperator 2021-05-06T15:15:02.963042+00:00 2021-05-06T15:15:04.710086+00:00 0:00:01.747044 25139 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-06T15:15:00.655884+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-06T14:00:00+00:00 EmrCreateJobFlowOperator 2021-05-06T15:14:54.996993+00:00 2021-05-06T15:14:56.813025+00:00 0:00:01.816032 25138 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-06T15:14:52.473934+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-06T14:00:00+00:00 PythonOperator 2021-05-06T15:14:40.644988+00:00 2021-05-06T15:14:43.992624+00:00 0:00:03.347636 25137 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T15:14:38.475557+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-06T14:00:00+00:00 PythonOperator 2021-05-06T15:14:32.804218+00:00 2021-05-06T15:14:35.839839+00:00 0:00:03.035621 25136 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T15:14:30.486194+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-06T14:00:00+00:00 TriggerDagRunOperator 2021-05-06T15:14:16.738642+00:00 2021-05-06T15:14:17.265599+00:00 0:00:00.526957 25135 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T15:14:14.446721+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-06T14:00:00+00:00 TriggerDagRunOperator 2021-05-06T15:14:16.573365+00:00 2021-05-06T15:14:16.994531+00:00 0:00:00.421166 25134 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T15:14:14.446753+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-06T14:05:00+00:00 EmrJobFlowSensor 2021-05-06T15:05:49.940363+00:00 2021-05-06T15:14:52.735646+00:00 0:09:02.795283 25133 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T15:05:47.634407+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-06T14:05:00+00:00 EmrCreateJobFlowOperator 2021-05-06T15:05:27.926380+00:00 2021-05-06T15:05:29.715275+00:00 0:00:01.788895 25132 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-06T15:05:25.613909+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-06T14:05:00+00:00 PythonOperator 2021-05-06T15:05:07.822682+00:00 2021-05-06T15:05:10.846224+00:00 0:00:03.023542 25131 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T15:05:05.593614+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-06T14:00:00+00:00 EmrJobFlowSensor 2021-05-06T15:03:56.153774+00:00 2021-05-06T15:13:59.138336+00:00 0:10:02.984562 25130 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T15:03:53.574023+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-06T14:00:00+00:00 EmrCreateJobFlowOperator 2021-05-06T15:03:17.634933+00:00 2021-05-06T15:03:19.374483+00:00 0:00:01.739550 25129 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-06T15:03:15.480475+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-06T14:00:00+00:00 PythonOperator 2021-05-06T15:02:56.010246+00:00 2021-05-06T15:02:59.284869+00:00 0:00:03.274623 25128 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-06T15:02:53.461589+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-06T13:00:00+00:00 EmrJobFlowSensor 2021-05-06T14:11:38.230786+00:00 2021-05-06T14:21:40.974829+00:00 0:10:02.744043 25126 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T14:11:36.037570+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-06T13:00:00+00:00 EmrJobFlowSensor 2021-05-06T14:11:28.175602+00:00 2021-05-06T14:20:30.695638+00:00 0:09:02.520036 25125 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T14:11:26.030158+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-06T13:00:00+00:00 EmrCreateJobFlowOperator 2021-05-06T14:11:16.393072+00:00 2021-05-06T14:11:18.078050+00:00 0:00:01.684978 25124 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-06T14:11:14.076477+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-06T13:00:00+00:00 EmrCreateJobFlowOperator 2021-05-06T14:11:06.100134+00:00 2021-05-06T14:11:07.782257+00:00 0:00:01.682123 25123 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-06T14:11:04.015474+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-06T13:00:00+00:00 PythonOperator 2021-05-06T14:10:56.183795+00:00 2021-05-06T14:10:59.558429+00:00 0:00:03.374634 25122 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T14:10:54.047961+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-06T13:00:00+00:00 PythonOperator 2021-05-06T14:10:44.645137+00:00 2021-05-06T14:10:47.655257+00:00 0:00:03.010120 25121 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T14:10:41.994087+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-06T13:00:00+00:00 TriggerDagRunOperator 2021-05-06T14:10:36.238150+00:00 2021-05-06T14:10:36.773093+00:00 0:00:00.534943 25120 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T14:10:33.989128+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-06T13:00:00+00:00 TriggerDagRunOperator 2021-05-06T14:10:36.185647+00:00 2021-05-06T14:10:36.603288+00:00 0:00:00.417641 25119 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T14:10:33.989093+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-06T13:05:00+00:00 EmrJobFlowSensor 2021-05-06T14:05:55.787078+00:00 2021-05-06T14:14:58.723687+00:00 0:09:02.936609 25118 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T14:05:53.284076+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-06T13:05:00+00:00 EmrCreateJobFlowOperator 2021-05-06T14:05:35.491767+00:00 2021-05-06T14:05:37.251524+00:00 0:00:01.759757 25117 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-06T14:05:33.262529+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-06T13:05:00+00:00 PythonOperator 2021-05-06T14:05:13.414216+00:00 2021-05-06T14:05:16.408598+00:00 0:00:02.994382 25116 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T14:05:11.193198+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-06T13:00:00+00:00 EmrJobFlowSensor 2021-05-06T14:01:08.921094+00:00 2021-05-06T14:10:11.702768+00:00 0:09:02.781674 25115 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T14:01:06.788722+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-06T13:00:00+00:00 EmrCreateJobFlowOperator 2021-05-06T14:00:46.836155+00:00 2021-05-06T14:00:48.531238+00:00 0:00:01.695083 25114 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-06T14:00:44.748549+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-06T13:00:00+00:00 PythonOperator 2021-05-06T14:00:25.186778+00:00 2021-05-06T14:00:28.268707+00:00 0:00:03.081929 25113 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-06T14:00:22.757790+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-06T12:00:00+00:00 EmrJobFlowSensor 2021-05-06T13:12:13.399695+00:00 2021-05-06T13:21:16.282027+00:00 0:09:02.882332 25111 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T13:12:10.847742+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-06T12:00:00+00:00 EmrJobFlowSensor 2021-05-06T13:12:13.136770+00:00 2021-05-06T13:23:16.011522+00:00 0:11:02.874752 25110 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T13:12:10.847777+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-06T12:00:00+00:00 EmrCreateJobFlowOperator 2021-05-06T13:11:51.302523+00:00 2021-05-06T13:11:53.130635+00:00 0:00:01.828112 25109 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-06T13:11:48.775542+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-06T12:00:00+00:00 EmrCreateJobFlowOperator 2021-05-06T13:11:51.138680+00:00 2021-05-06T13:11:52.864261+00:00 0:00:01.725581 25108 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-06T13:11:48.775490+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-06T12:00:00+00:00 PythonOperator 2021-05-06T13:11:26.946707+00:00 2021-05-06T13:11:29.975216+00:00 0:00:03.028509 25107 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T13:11:24.713510+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-06T12:00:00+00:00 PythonOperator 2021-05-06T13:11:23.008301+00:00 2021-05-06T13:11:26.322882+00:00 0:00:03.314581 25106 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T13:11:20.696076+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-06T12:00:00+00:00 TriggerDagRunOperator 2021-05-06T13:11:09.182192+00:00 2021-05-06T13:11:09.611094+00:00 0:00:00.428902 25105 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T13:11:06.690982+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-06T12:00:00+00:00 TriggerDagRunOperator 2021-05-06T13:11:09.183219+00:00 2021-05-06T13:11:09.743766+00:00 0:00:00.560547 25104 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T13:11:06.690948+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-06T12:05:00+00:00 EmrJobFlowSensor 2021-05-06T13:05:50.538772+00:00 2021-05-06T13:14:53.118619+00:00 0:09:02.579847 25103 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T13:05:48.268392+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-06T12:05:00+00:00 EmrCreateJobFlowOperator 2021-05-06T13:05:28.550407+00:00 2021-05-06T13:05:30.311048+00:00 0:00:01.760641 25102 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-06T13:05:26.183083+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-06T12:05:00+00:00 PythonOperator 2021-05-06T13:05:06.140636+00:00 2021-05-06T13:05:09.258901+00:00 0:00:03.118265 25101 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T13:05:04.119685+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-06T12:00:00+00:00 EmrJobFlowSensor 2021-05-06T13:00:45.893347+00:00 2021-05-06T13:10:48.779346+00:00 0:10:02.885999 25100 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T13:00:43.725339+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-06T12:00:00+00:00 EmrCreateJobFlowOperator 2021-05-06T13:00:25.893673+00:00 2021-05-06T13:00:27.628736+00:00 0:00:01.735063 25099 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-06T13:00:23.706750+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-06T12:00:00+00:00 PythonOperator 2021-05-06T13:00:03.976683+00:00 2021-05-06T13:00:07.185399+00:00 0:00:03.208716 25098 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-06T13:00:01.697227+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-06T11:00:00+00:00 EmrJobFlowSensor 2021-05-06T12:27:52.887683+00:00 2021-05-06T12:36:55.565108+00:00 0:09:02.677425 25097 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T12:27:50.450044+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-06T11:00:00+00:00 EmrJobFlowSensor 2021-05-06T12:27:42.485574+00:00 2021-05-06T12:36:45.271018+00:00 0:09:02.785444 25096 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T12:27:40.325293+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-06T11:05:00+00:00 EmrJobFlowSensor 2021-05-06T12:27:32.605830+00:00 2021-05-06T12:36:35.411472+00:00 0:09:02.805642 25095 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T12:27:30.321092+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-06T11:00:00+00:00 EmrCreateJobFlowOperator 2021-05-06T12:27:16.386953+00:00 2021-05-06T12:27:18.055692+00:00 0:00:01.668739 25094 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-06T12:27:14.305371+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-06T11:00:00+00:00 EmrCreateJobFlowOperator 2021-05-06T12:27:14.707935+00:00 2021-05-06T12:27:16.541850+00:00 0:00:01.833915 25093 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-06T12:27:12.304855+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-06T11:05:00+00:00 EmrCreateJobFlowOperator 2021-05-06T12:27:04.533254+00:00 2021-05-06T12:27:06.205126+00:00 0:00:01.671872 25092 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-06T12:27:02.295510+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-06T11:00:00+00:00 PythonOperator 2021-05-06T12:26:54.966467+00:00 2021-05-06T12:26:58.353343+00:00 0:00:03.386876 25091 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T12:26:52.296851+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-06T11:00:00+00:00 PythonOperator 2021-05-06T12:26:54.509994+00:00 2021-05-06T12:26:57.577652+00:00 0:00:03.067658 25090 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T12:26:52.296810+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-06T11:05:00+00:00 PythonOperator 2021-05-06T12:26:44.883258+00:00 2021-05-06T12:26:47.930328+00:00 0:00:03.047070 25089 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T12:26:42.266033+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-06T11:00:00+00:00 TriggerDagRunOperator 2021-05-06T12:26:36.916531+00:00 2021-05-06T12:26:37.505321+00:00 0:00:00.588790 25088 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T12:26:34.271721+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-06T11:00:00+00:00 TriggerDagRunOperator 2021-05-06T12:26:36.774119+00:00 2021-05-06T12:26:37.175620+00:00 0:00:00.401501 25087 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T12:26:34.271693+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-06T11:00:00+00:00 EmrJobFlowSensor 2021-05-06T12:00:56.104985+00:00 2021-05-06T12:10:59.011858+00:00 0:10:02.906873 25085 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T12:00:53.781083+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-06T11:00:00+00:00 EmrCreateJobFlowOperator 2021-05-06T12:00:34.059749+00:00 2021-05-06T12:00:35.993604+00:00 0:00:01.933855 25084 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-06T12:00:31.696695+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-06T11:00:00+00:00 PythonOperator 2021-05-06T12:00:11.682856+00:00 2021-05-06T12:00:14.755247+00:00 0:00:03.072391 25083 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-06T12:00:09.571320+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-06T10:00:00+00:00 EmrJobFlowSensor 2021-05-06T11:13:54.717429+00:00 2021-05-06T11:23:57.364407+00:00 0:10:02.646978 25082 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T11:13:52.602614+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-06T10:00:00+00:00 EmrJobFlowSensor 2021-05-06T11:13:50.676704+00:00 2021-05-06T11:23:53.469223+00:00 0:10:02.792519 25081 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T11:13:48.611566+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-06T10:00:00+00:00 EmrCreateJobFlowOperator 2021-05-06T11:13:32.829325+00:00 2021-05-06T11:13:34.493172+00:00 0:00:01.663847 25080 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-06T11:13:30.648437+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-06T10:00:00+00:00 EmrCreateJobFlowOperator 2021-05-06T11:13:28.890876+00:00 2021-05-06T11:13:30.625875+00:00 0:00:01.734999 25079 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-06T11:13:26.579233+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-06T10:00:00+00:00 PythonOperator 2021-05-06T11:13:11.115017+00:00 2021-05-06T11:13:14.200375+00:00 0:00:03.085358 25078 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T11:13:08.646817+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-06T10:00:00+00:00 PythonOperator 2021-05-06T11:13:08.789132+00:00 2021-05-06T11:13:12.069149+00:00 0:00:03.280017 25077 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T11:13:06.552673+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-06T10:00:00+00:00 TriggerDagRunOperator 2021-05-06T11:12:51.036345+00:00 2021-05-06T11:12:51.564295+00:00 0:00:00.527950 25076 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T11:12:48.556352+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-06T10:00:00+00:00 TriggerDagRunOperator 2021-05-06T11:12:50.874038+00:00 2021-05-06T11:12:51.296089+00:00 0:00:00.422051 25075 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T11:12:48.556400+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-06T10:05:00+00:00 EmrJobFlowSensor 2021-05-06T11:05:51.981496+00:00 2021-05-06T11:14:54.694395+00:00 0:09:02.712899 25074 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T11:05:49.800644+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-06T10:05:00+00:00 EmrCreateJobFlowOperator 2021-05-06T11:05:30.404410+00:00 2021-05-06T11:05:32.101126+00:00 0:00:01.696716 25073 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-06T11:05:27.864293+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-06T10:05:00+00:00 PythonOperator 2021-05-06T11:05:07.943136+00:00 2021-05-06T11:05:10.963168+00:00 0:00:03.020032 25072 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T11:05:05.752444+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-06T10:00:00+00:00 EmrJobFlowSensor 2021-05-06T11:03:25.923521+00:00 2021-05-06T11:12:28.886662+00:00 0:09:02.963141 25071 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T11:03:23.586672+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-06T10:00:00+00:00 EmrCreateJobFlowOperator 2021-05-06T11:03:05.732142+00:00 2021-05-06T11:03:07.426461+00:00 0:00:01.694319 25070 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-06T11:03:03.549580+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-06T10:00:00+00:00 PythonOperator 2021-05-06T11:02:44.200570+00:00 2021-05-06T11:02:47.285550+00:00 0:00:03.084980 25069 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-06T11:02:41.531367+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-06T09:00:00+00:00 EmrJobFlowSensor 2021-05-06T10:10:07.607113+00:00 2021-05-06T10:19:10.263184+00:00 0:09:02.656071 25067 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T10:10:05.357965+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-06T09:00:00+00:00 EmrJobFlowSensor 2021-05-06T10:09:57.464366+00:00 2021-05-06T10:20:00.384237+00:00 0:10:02.919871 25066 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T10:09:55.238539+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-06T09:00:00+00:00 EmrCreateJobFlowOperator 2021-05-06T10:09:47.383064+00:00 2021-05-06T10:09:49.038209+00:00 0:00:01.655145 25065 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-06T10:09:45.244588+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-06T09:00:00+00:00 EmrCreateJobFlowOperator 2021-05-06T10:09:35.392583+00:00 2021-05-06T10:09:37.053722+00:00 0:00:01.661139 25064 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-06T10:09:33.184492+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-06T09:00:00+00:00 PythonOperator 2021-05-06T10:09:25.423596+00:00 2021-05-06T10:09:28.443024+00:00 0:00:03.019428 25063 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T10:09:23.158403+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-06T09:00:00+00:00 PythonOperator 2021-05-06T10:09:13.265345+00:00 2021-05-06T10:09:17.192722+00:00 0:00:03.927377 25062 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T10:09:11.085543+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-06T09:00:00+00:00 TriggerDagRunOperator 2021-05-06T10:09:09.383916+00:00 2021-05-06T10:09:09.921034+00:00 0:00:00.537118 25061 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T10:09:07.029526+00:00 2 default_pool