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 booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-04T00:00:00+00:00 EmrCreateJobFlowOperator 2021-05-04T01:09:40.952502+00:00 2021-05-04T01:09:42.637238+00:00 0:00:01.684736 24206 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-04T01:09:38.790594+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-04T00:00:00+00:00 EmrCreateJobFlowOperator 2021-05-04T01:09:36.992038+00:00 2021-05-04T01:09:38.784664+00:00 0:00:01.792626 24205 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-04T01:09:34.786076+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-04T00:00:00+00:00 PythonOperator 2021-05-04T01:09:19.768152+00:00 2021-05-04T01:09:23.163752+00:00 0:00:03.395600 24204 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T01:09:16.781004+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-04T00:00:00+00:00 PythonOperator 2021-05-04T01:09:15.197636+00:00 2021-05-04T01:09:19.245025+00:00 0:00:04.047389 24203 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T01:09:12.776937+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-04T00:00:00+00:00 TriggerDagRunOperator 2021-05-04T01:09:09.410355+00:00 2021-05-04T01:09:09.918476+00:00 0:00:00.508121 24202 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T01:09:06.846807+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-04T00:00:00+00:00 TriggerDagRunOperator 2021-05-04T01:09:09.236510+00:00 2021-05-04T01:09:09.652560+00:00 0:00:00.416050 24201 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T01:09:06.846747+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-04T00:05:00+00:00 EmrJobFlowSensor 2021-05-04T01:05:54.532058+00:00 2021-05-04T01:14:57.144725+00:00 0:09:02.612667 24200 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T01:05:52.304813+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-04T00:05:00+00:00 EmrCreateJobFlowOperator 2021-05-04T01:05:32.484153+00:00 2021-05-04T01:05:34.257300+00:00 0:00:01.773147 24199 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-04T01:05:30.283291+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-04T00:05:00+00:00 PythonOperator 2021-05-04T01:05:10.582683+00:00 2021-05-04T01:05:13.574108+00:00 0:00:02.991425 24198 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T01:05:08.262788+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-04T00:00:00+00:00 EmrJobFlowSensor 2021-05-04T01:00:56.165236+00:00 2021-05-04T01:08:58.652087+00:00 0:08:02.486851 24197 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T01:00:53.849690+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-04T00:00:00+00:00 EmrCreateJobFlowOperator 2021-05-04T01:00:34.118868+00:00 2021-05-04T01:00:35.851606+00:00 0:00:01.732738 24196 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-04T01:00:31.783657+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-04T00:00:00+00:00 PythonOperator 2021-05-04T01:00:14.331420+00:00 2021-05-04T01:00:17.443751+00:00 0:00:03.112331 24195 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-04T01:00:11.765655+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-03T23:00:00+00:00 EmrJobFlowSensor 2021-05-04T00:11:30.023520+00:00 2021-05-04T00:21:32.844972+00:00 0:10:02.821452 24193 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T00:11:27.477407+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-03T23:00:00+00:00 EmrJobFlowSensor 2021-05-04T00:11:13.833218+00:00 2021-05-04T00:19:16.356031+00:00 0:08:02.522813 24192 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T00:11:11.458046+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-03T23:00:00+00:00 EmrCreateJobFlowOperator 2021-05-04T00:11:09.903671+00:00 2021-05-04T00:11:11.719997+00:00 0:00:01.816326 24191 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-04T00:11:07.480794+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-03T23:00:00+00:00 EmrCreateJobFlowOperator 2021-05-04T00:10:52.154517+00:00 2021-05-04T00:10:53.867069+00:00 0:00:01.712552 24190 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-04T00:10:49.385757+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-03T23:00:00+00:00 PythonOperator 2021-05-04T00:10:47.770818+00:00 2021-05-04T00:10:51.747400+00:00 0:00:03.976582 24189 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T00:10:45.386192+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-03T23:00:00+00:00 PythonOperator 2021-05-04T00:10:31.633596+00:00 2021-05-04T00:10:34.698608+00:00 0:00:03.065012 24188 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T00:10:29.350951+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-03T23:00:00+00:00 TriggerDagRunOperator 2021-05-04T00:10:25.831564+00:00 2021-05-04T00:10:26.356372+00:00 0:00:00.524808 24187 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T00:10:23.325472+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-03T23:00:00+00:00 TriggerDagRunOperator 2021-05-04T00:10:25.788443+00:00 2021-05-04T00:10:26.207348+00:00 0:00:00.418905 24186 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T00:10:23.325521+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-03T23:05:00+00:00 EmrJobFlowSensor 2021-05-04T00:05:57.239525+00:00 2021-05-04T00:14:59.864522+00:00 0:09:02.624997 24185 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T00:05:54.907936+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-03T23:05:00+00:00 EmrCreateJobFlowOperator 2021-05-04T00:05:35.263299+00:00 2021-05-04T00:05:36.961690+00:00 0:00:01.698391 24184 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-04T00:05:32.957372+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-03T23:05:00+00:00 PythonOperator 2021-05-04T00:05:13.135275+00:00 2021-05-04T00:05:16.133122+00:00 0:00:02.997847 24183 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T00:05:10.845776+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-03T23:00:00+00:00 EmrJobFlowSensor 2021-05-04T00:01:04.939213+00:00 2021-05-04T00:10:07.889066+00:00 0:09:02.949853 24182 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T00:01:02.485968+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-03T23:00:00+00:00 EmrCreateJobFlowOperator 2021-05-04T00:00:44.641353+00:00 2021-05-04T00:00:46.306723+00:00 0:00:01.665370 24181 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-04T00:00:42.439341+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-03T23:00:00+00:00 PythonOperator 2021-05-04T00:00:23.371505+00:00 2021-05-04T00:00:26.504913+00:00 0:00:03.133408 24180 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-04T00:00:20.479726+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-03T22:00:00+00:00 EmrJobFlowSensor 2021-05-03T23:10:30.237790+00:00 2021-05-03T23:20:32.956384+00:00 0:10:02.718594 24178 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T23:10:27.943905+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-03T22:00:00+00:00 EmrJobFlowSensor 2021-05-03T23:10:18.141845+00:00 2021-05-03T23:20:21.056486+00:00 0:10:02.914641 24177 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T23:10:15.922080+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-03T22:00:00+00:00 EmrCreateJobFlowOperator 2021-05-03T23:10:08.446302+00:00 2021-05-03T23:10:10.285064+00:00 0:00:01.838762 24176 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-03T23:10:05.978615+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-03T22:00:00+00:00 EmrCreateJobFlowOperator 2021-05-03T23:09:56.305410+00:00 2021-05-03T23:09:58.102094+00:00 0:00:01.796684 24175 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-03T23:09:53.975365+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-03T22:00:00+00:00 PythonOperator 2021-05-03T23:09:46.162494+00:00 2021-05-03T23:09:49.373034+00:00 0:00:03.210540 24174 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-03T23:09:43.900861+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-03T22:00:00+00:00 PythonOperator 2021-05-03T23:09:34.312422+00:00 2021-05-03T23:09:37.493036+00:00 0:00:03.180614 24173 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-03T23:09:31.947721+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-03T22:00:00+00:00 TriggerDagRunOperator 2021-05-03T23:09:22.550360+00:00 2021-05-03T23:09:23.025037+00:00 0:00:00.474677 24172 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T23:09:19.859527+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-03T22:00:00+00:00 TriggerDagRunOperator 2021-05-03T23:09:22.105725+00:00 2021-05-03T23:09:22.682240+00:00 0:00:00.576515 24171 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T23:09:19.859491+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-03T22:05:00+00:00 EmrJobFlowSensor 2021-05-03T23:06:11.794137+00:00 2021-05-03T23:14:14.229799+00:00 0:08:02.435662 24170 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T23:06:09.619984+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-03T22:05:00+00:00 EmrCreateJobFlowOperator 2021-05-03T23:05:49.983829+00:00 2021-05-03T23:05:51.674454+00:00 0:00:01.690625 24169 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-03T23:05:47.659019+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-03T22:05:00+00:00 PythonOperator 2021-05-03T23:05:21.783823+00:00 2021-05-03T23:05:24.778230+00:00 0:00:02.994407 24168 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-03T23:05:19.561447+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-03T22:00:00+00:00 EmrJobFlowSensor 2021-05-03T23:01:11.238389+00:00 2021-05-03T23:09:13.812733+00:00 0:08:02.574344 24167 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-03T23:01:09.099189+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2021-05-02T23:00:00+00:00 EmrJobFlowSensor 2021-05-03T23:00:53.264974+00:00 2021-05-03T23:10:56.084990+00:00 0:10:02.820016 24166 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T23:00:51.085279+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-03T22:00:00+00:00 EmrCreateJobFlowOperator 2021-05-03T23:00:47.376736+00:00 2021-05-03T23:00:49.101363+00:00 0:00:01.724627 24165 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-03T23:00:45.160767+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2021-05-02T23:00:00+00:00 EmrCreateJobFlowOperator 2021-05-03T23:00:33.198473+00:00 2021-05-03T23:00:34.987868+00:00 0:00:01.789395 24164 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-03T23:00:31.053695+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-03T22:00:00+00:00 PythonOperator 2021-05-03T23:00:23.223083+00:00 2021-05-03T23:00:26.233100+00:00 0:00:03.010017 24163 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-03T23:00:21.036098+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2021-05-02T23:00:00+00:00 PythonOperator 2021-05-03T23:00:05.565800+00:00 2021-05-03T23:00:08.724224+00:00 0:00:03.158424 24162 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-03T23:00:03.022901+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-03T21:00:00+00:00 EmrJobFlowSensor 2021-05-03T22:10:36.664570+00:00 2021-05-03T22:18:39.116176+00:00 0:08:02.451606 24160 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T22:10:34.385479+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-03T21:00:00+00:00 EmrJobFlowSensor 2021-05-03T22:10:34.840709+00:00 2021-05-03T22:20:37.844976+00:00 0:10:03.004267 24159 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T22:10:32.460891+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-03T21:00:00+00:00 EmrCreateJobFlowOperator 2021-05-03T22:10:15.502084+00:00 2021-05-03T22:10:17.535947+00:00 0:00:02.033863 24158 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-03T22:10:12.355003+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-03T21:00:00+00:00 EmrCreateJobFlowOperator 2021-05-03T22:10:12.919432+00:00 2021-05-03T22:10:15.161623+00:00 0:00:02.242191 24157 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-03T22:10:10.446030+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-03T21:00:00+00:00 PythonOperator 2021-05-03T22:09:52.528859+00:00 2021-05-03T22:09:55.812364+00:00 0:00:03.283505 24156 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-03T22:09:50.290638+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-03T21:00:00+00:00 PythonOperator 2021-05-03T22:09:52.576752+00:00 2021-05-03T22:09:55.701176+00:00 0:00:03.124424 24155 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-03T22:09:50.290606+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-03T21:00:00+00:00 TriggerDagRunOperator 2021-05-03T22:09:30.753785+00:00 2021-05-03T22:09:31.227893+00:00 0:00:00.474108 24154 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T22:09:28.148292+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-03T21:00:00+00:00 TriggerDagRunOperator 2021-05-03T22:09:30.733836+00:00 2021-05-03T22:09:31.320458+00:00 0:00:00.586622 24153 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T22:09:28.148342+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-03T21:05:00+00:00 EmrJobFlowSensor 2021-05-03T22:06:04.088909+00:00 2021-05-03T22:14:06.604808+00:00 0:08:02.515899 24152 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T22:06:01.802947+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-03T21:05:00+00:00 EmrCreateJobFlowOperator 2021-05-03T22:05:41.903569+00:00 2021-05-03T22:05:43.548646+00:00 0:00:01.645077 24151 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-03T22:05:39.781328+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-03T21:05:00+00:00 PythonOperator 2021-05-03T22:05:21.902378+00:00 2021-05-03T22:05:24.969214+00:00 0:00:03.066836 24150 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-03T22:05:19.763012+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-03T21:00:00+00:00 EmrJobFlowSensor 2021-05-03T22:01:05.511565+00:00 2021-05-03T22:09:08.174402+00:00 0:08:02.662837 24149 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-03T22:01:03.268985+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-03T21:00:00+00:00 EmrCreateJobFlowOperator 2021-05-03T22:00:41.404774+00:00 2021-05-03T22:00:43.236264+00:00 0:00:01.831490 24148 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-03T22:00:39.210529+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-03T21:00:00+00:00 PythonOperator 2021-05-03T22:00:19.817900+00:00 2021-05-03T22:00:22.859416+00:00 0:00:03.041516 24147 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-03T22:00:17.260346+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-03T20:00:00+00:00 EmrJobFlowSensor 2021-05-03T21:11:17.537445+00:00 2021-05-03T21:20:20.211895+00:00 0:09:02.674450 24145 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T21:11:15.359510+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-03T20:00:00+00:00 EmrJobFlowSensor 2021-05-03T21:11:07.557529+00:00 2021-05-03T21:21:10.299019+00:00 0:10:02.741490 24144 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T21:11:05.325539+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-03T20:00:00+00:00 EmrCreateJobFlowOperator 2021-05-03T21:10:55.489598+00:00 2021-05-03T21:10:57.152371+00:00 0:00:01.662773 24143 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-03T21:10:53.315380+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-03T20:00:00+00:00 EmrCreateJobFlowOperator 2021-05-03T21:10:45.711952+00:00 2021-05-03T21:10:47.537195+00:00 0:00:01.825243 24142 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-03T21:10:43.309157+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-03T20:00:00+00:00 PythonOperator 2021-05-03T21:10:35.623762+00:00 2021-05-03T21:10:38.891048+00:00 0:00:03.267286 24141 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-03T21:10:33.299006+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-03T20:00:00+00:00 PythonOperator 2021-05-03T21:10:25.678739+00:00 2021-05-03T21:10:28.993068+00:00 0:00:03.314329 24140 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-03T21:10:23.292834+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-03T20:00:00+00:00 TriggerDagRunOperator 2021-05-03T21:10:19.933684+00:00 2021-05-03T21:10:20.429830+00:00 0:00:00.496146 24139 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T21:10:17.347979+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-03T20:00:00+00:00 TriggerDagRunOperator 2021-05-03T21:10:19.830842+00:00 2021-05-03T21:10:20.240488+00:00 0:00:00.409646 24138 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T21:10:17.347930+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-03T20:05:00+00:00 EmrJobFlowSensor 2021-05-03T21:06:06.997200+00:00 2021-05-03T21:15:09.702920+00:00 0:09:02.705720 24137 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T21:06:04.768904+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-03T20:05:00+00:00 EmrCreateJobFlowOperator 2021-05-03T21:05:40.868666+00:00 2021-05-03T21:05:42.581388+00:00 0:00:01.712722 24136 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-03T21:05:38.720750+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-03T20:05:00+00:00 PythonOperator 2021-05-03T21:05:17.029454+00:00 2021-05-03T21:05:20.053376+00:00 0:00:03.023922 24135 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-03T21:05:14.747506+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-03T20:00:00+00:00 EmrJobFlowSensor 2021-05-03T21:01:03.037417+00:00 2021-05-03T21:10:05.730967+00:00 0:09:02.693550 24134 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-03T21:01:00.450208+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-03T20:00:00+00:00 EmrCreateJobFlowOperator 2021-05-03T21:00:40.615319+00:00 2021-05-03T21:00:42.338452+00:00 0:00:01.723133 24133 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-03T21:00:38.263165+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-03T20:00:00+00:00 PythonOperator 2021-05-03T21:00:20.594703+00:00 2021-05-03T21:00:23.665400+00:00 0:00:03.070697 24132 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-03T21:00:18.189804+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-03T19:00:00+00:00 EmrJobFlowSensor 2021-05-03T20:11:07.609305+00:00 2021-05-03T20:20:10.281987+00:00 0:09:02.672682 24130 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T20:11:05.345744+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-03T19:00:00+00:00 EmrJobFlowSensor 2021-05-03T20:10:53.546213+00:00 2021-05-03T20:20:56.545608+00:00 0:10:02.999395 24129 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T20:10:51.205944+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-03T19:00:00+00:00 EmrCreateJobFlowOperator 2021-05-03T20:10:45.433241+00:00 2021-05-03T20:10:47.108377+00:00 0:00:01.675136 24128 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-03T20:10:43.198695+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-03T19:00:00+00:00 EmrCreateJobFlowOperator 2021-05-03T20:10:33.391081+00:00 2021-05-03T20:10:35.155718+00:00 0:00:01.764637 24127 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-03T20:10:31.187677+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-03T19:00:00+00:00 PythonOperator 2021-05-03T20:10:25.422304+00:00 2021-05-03T20:10:28.491672+00:00 0:00:03.069368 24126 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-03T20:10:23.179489+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-03T19:00:00+00:00 PythonOperator 2021-05-03T20:10:11.956561+00:00 2021-05-03T20:10:15.246025+00:00 0:00:03.289464 24125 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-03T20:10:09.242089+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-03T19:00:00+00:00 TriggerDagRunOperator 2021-05-03T20:10:03.847193+00:00 2021-05-03T20:10:04.293757+00:00 0:00:00.446564 24124 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T20:10:01.257695+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-03T19:00:00+00:00 TriggerDagRunOperator 2021-05-03T20:10:03.715147+00:00 2021-05-03T20:10:04.230283+00:00 0:00:00.515136 24123 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T20:10:01.257750+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-03T19:05:00+00:00 EmrJobFlowSensor 2021-05-03T20:06:59.097201+00:00 2021-05-03T20:16:01.680707+00:00 0:09:02.583506 24122 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T20:06:56.781349+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-03T19:05:00+00:00 EmrCreateJobFlowOperator 2021-05-03T20:06:36.917693+00:00 2021-05-03T20:06:38.553168+00:00 0:00:01.635475 24121 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-03T20:06:34.714633+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-03T19:05:00+00:00 PythonOperator 2021-05-03T20:06:17.004379+00:00 2021-05-03T20:06:19.993609+00:00 0:00:02.989230 24120 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-03T20:06:14.700127+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-03T19:00:00+00:00 EmrJobFlowSensor 2021-05-03T20:00:46.425286+00:00 2021-05-03T20:09:49.140441+00:00 0:09:02.715155 24119 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-03T20:00:44.220372+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-03T19:00:00+00:00 EmrCreateJobFlowOperator 2021-05-03T20:00:26.390428+00:00 2021-05-03T20:00:28.130706+00:00 0:00:01.740278 24118 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-03T20:00:24.201792+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-03T19:00:00+00:00 PythonOperator 2021-05-03T20:00:05.046372+00:00 2021-05-03T20:00:08.336299+00:00 0:00:03.289927 24117 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-03T20:00:02.184236+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-03T18:00:00+00:00 EmrJobFlowSensor 2021-05-03T19:11:09.911973+00:00 2021-05-03T19:21:12.653232+00:00 0:10:02.741259 24115 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T19:11:07.586994+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-03T18:00:00+00:00 EmrJobFlowSensor 2021-05-03T19:11:07.842528+00:00 2021-05-03T19:20:10.587302+00:00 0:09:02.744774 24114 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T19:11:05.586970+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-03T18:00:00+00:00 EmrCreateJobFlowOperator 2021-05-03T19:10:47.888585+00:00 2021-05-03T19:10:49.738904+00:00 0:00:01.850319 24113 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-03T19:10:45.556325+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-03T18:00:00+00:00 EmrCreateJobFlowOperator 2021-05-03T19:10:47.803350+00:00 2021-05-03T19:10:49.516587+00:00 0:00:01.713237 24112 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-03T19:10:45.556355+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-03T18:00:00+00:00 PythonOperator 2021-05-03T19:10:26.235741+00:00 2021-05-03T19:10:29.329741+00:00 0:00:03.094000 24111 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-03T19:10:23.566383+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-03T18:00:00+00:00 PythonOperator 2021-05-03T19:10:25.994123+00:00 2021-05-03T19:10:29.320655+00:00 0:00:03.326532 24110 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-03T19:10:23.566351+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-03T18:00:00+00:00 TriggerDagRunOperator 2021-05-03T19:10:04.035517+00:00 2021-05-03T19:10:04.454744+00:00 0:00:00.419227 24109 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T19:10:01.567910+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-03T18:00:00+00:00 TriggerDagRunOperator 2021-05-03T19:10:03.940045+00:00 2021-05-03T19:10:04.491801+00:00 0:00:00.551756 24108 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T19:10:01.567945+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-03T18:05:00+00:00 EmrJobFlowSensor 2021-05-03T19:05:47.240633+00:00 2021-05-03T19:13:49.578397+00:00 0:08:02.337764 24107 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T19:05:45.064621+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-03T18:05:00+00:00 EmrCreateJobFlowOperator 2021-05-03T19:05:25.274931+00:00 2021-05-03T19:05:26.986610+00:00 0:00:01.711679 24106 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-03T19:05:22.965688+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-03T18:05:00+00:00 PythonOperator 2021-05-03T19:05:05.261181+00:00 2021-05-03T19:05:08.253760+00:00 0:00:02.992579 24105 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-03T19:05:02.887765+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-03T18:00:00+00:00 EmrJobFlowSensor 2021-05-03T19:00:54.991745+00:00 2021-05-03T19:09:57.755235+00:00 0:09:02.763490 24104 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-03T19:00:52.664232+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-03T18:00:00+00:00 EmrCreateJobFlowOperator 2021-05-03T19:00:33.054858+00:00 2021-05-03T19:00:34.833394+00:00 0:00:01.778536 24103 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-03T19:00:30.555323+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-03T18:00:00+00:00 PythonOperator 2021-05-03T19:00:12.889741+00:00 2021-05-03T19:00:15.955689+00:00 0:00:03.065948 24102 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-03T19:00:10.491734+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-03T17:00:00+00:00 EmrJobFlowSensor 2021-05-03T18:12:11.068922+00:00 2021-05-03T18:21:13.802783+00:00 0:09:02.733861 24100 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T18:12:08.891013+00:00 2 default_pool