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 vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-03T23:05:00+00:00 EmrCreateJobFlowOperator 2021-04-04T00:05:36.041697+00:00 2021-04-04T00:05:37.680845+00:00 0:00:01.639148 13294 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T00:05:33.833861+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-03T23:05:00+00:00 PythonOperator 2021-04-04T00:05:12.185038+00:00 2021-04-04T00:05:14.995832+00:00 0:00:02.810794 13293 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T00:05:09.864175+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-03T23:00:00+00:00 EmrJobFlowSensor 2021-04-04T00:00:51.666535+00:00 2021-04-04T00:10:54.650394+00:00 0:10:02.983859 13292 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T00:00:49.325077+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-03T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T00:00:32.023269+00:00 2021-04-04T00:00:33.738175+00:00 0:00:01.714906 13291 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-04T00:00:29.468143+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-03T23:00:00+00:00 PythonOperator 2021-04-04T00:00:09.646081+00:00 2021-04-04T00:00:12.474727+00:00 0:00:02.828646 13290 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-04T00:00:07.290141+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-03T22:00:00+00:00 EmrJobFlowSensor 2021-04-03T23:24:13.231780+00:00 2021-04-03T23:24:14.721450+00:00 0:00:01.489670 13288 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T23:24:10.876204+00:00 3 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-03T22:00:00+00:00 EmrJobFlowSensor 2021-04-03T23:24:07.099662+00:00 2021-04-03T23:24:08.590069+00:00 0:00:01.490407 13287 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T23:24:04.870930+00:00 3 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-03T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T23:11:01.744987+00:00 2021-04-03T23:11:03.656666+00:00 0:00:01.911679 13284 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T23:10:59.433276+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-03T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T23:10:55.761759+00:00 2021-04-03T23:10:57.562924+00:00 0:00:01.801165 13283 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T23:10:53.426177+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-03T22:00:00+00:00 PythonOperator 2021-04-03T23:10:38.249167+00:00 2021-04-03T23:10:41.151849+00:00 0:00:02.902682 13282 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T23:10:35.404644+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-03T22:00:00+00:00 PythonOperator 2021-04-03T23:10:33.605543+00:00 2021-04-03T23:10:37.199766+00:00 0:00:03.594223 13281 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T23:10:31.401886+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-03T22:00:00+00:00 TriggerDagRunOperator 2021-04-03T23:10:27.680621+00:00 2021-04-03T23:10:28.215389+00:00 0:00:00.534768 13280 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T23:10:25.396543+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-03T22:00:00+00:00 TriggerDagRunOperator 2021-04-03T23:10:27.645688+00:00 2021-04-03T23:10:28.064570+00:00 0:00:00.418882 13279 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T23:10:25.396578+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-03T22:05:00+00:00 EmrJobFlowSensor 2021-04-03T23:06:01.156610+00:00 2021-04-03T23:15:03.749483+00:00 0:09:02.592873 13278 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T23:05:58.944865+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-03T22:05:00+00:00 EmrCreateJobFlowOperator 2021-04-03T23:05:39.186895+00:00 2021-04-03T23:05:40.841245+00:00 0:00:01.654350 13277 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T23:05:36.855554+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-03T22:05:00+00:00 PythonOperator 2021-04-03T23:05:16.865800+00:00 2021-04-03T23:05:19.530460+00:00 0:00:02.664660 13276 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T23:05:14.728703+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-03T22:00:00+00:00 EmrJobFlowSensor 2021-04-03T23:01:02.855353+00:00 2021-04-03T23:10:05.564487+00:00 0:09:02.709134 13275 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T23:01:00.455921+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-03T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T23:00:40.605344+00:00 2021-04-03T23:00:42.302893+00:00 0:00:01.697549 13274 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-03T23:00:38.344625+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-03T22:00:00+00:00 PythonOperator 2021-04-03T23:00:19.205981+00:00 2021-04-03T23:00:22.039622+00:00 0:00:02.833641 13273 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-03T23:00:16.372674+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-03T21:00:00+00:00 EmrJobFlowSensor 2021-04-03T22:11:12.888940+00:00 2021-04-03T22:20:15.567145+00:00 0:09:02.678205 13271 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T22:11:10.604671+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-03T21:00:00+00:00 EmrJobFlowSensor 2021-04-03T22:10:57.511601+00:00 2021-04-03T22:20:00.148006+00:00 0:09:02.636405 13270 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T22:10:54.662509+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-03T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T22:10:50.744861+00:00 2021-04-03T22:10:52.441310+00:00 0:00:01.696449 13269 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T22:10:48.588376+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-03T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T22:10:34.933003+00:00 2021-04-03T22:10:36.622177+00:00 0:00:01.689174 13268 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T22:10:32.572708+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-03T21:00:00+00:00 PythonOperator 2021-04-03T22:10:28.783265+00:00 2021-04-03T22:10:31.667355+00:00 0:00:02.884090 13267 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T22:10:26.512632+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-03T21:00:00+00:00 PythonOperator 2021-04-03T22:10:12.948713+00:00 2021-04-03T22:10:15.812756+00:00 0:00:02.864043 13266 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T22:10:10.497160+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-03T21:00:00+00:00 TriggerDagRunOperator 2021-04-03T22:10:06.911508+00:00 2021-04-03T22:10:07.429894+00:00 0:00:00.518386 13265 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T22:10:04.501280+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-03T21:00:00+00:00 TriggerDagRunOperator 2021-04-03T22:10:06.764652+00:00 2021-04-03T22:10:07.170392+00:00 0:00:00.405740 13264 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T22:10:04.501234+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-03T21:05:00+00:00 EmrJobFlowSensor 2021-04-03T22:05:46.368975+00:00 2021-04-03T22:14:49.113854+00:00 0:09:02.744879 13263 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T22:05:44.115900+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-03T21:05:00+00:00 EmrCreateJobFlowOperator 2021-04-03T22:05:26.621796+00:00 2021-04-03T22:05:28.324384+00:00 0:00:01.702588 13262 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T22:05:24.162802+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-03T21:05:00+00:00 PythonOperator 2021-04-03T22:05:04.274346+00:00 2021-04-03T22:05:06.995178+00:00 0:00:02.720832 13261 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T22:05:02.042187+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-03T21:00:00+00:00 EmrJobFlowSensor 2021-04-03T22:00:49.825943+00:00 2021-04-03T22:09:52.586429+00:00 0:09:02.760486 13260 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T22:00:47.656276+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-03T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T22:00:28.097205+00:00 2021-04-03T22:00:29.938067+00:00 0:00:01.840862 13259 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-03T22:00:25.637854+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-03T21:00:00+00:00 PythonOperator 2021-04-03T22:00:08.349493+00:00 2021-04-03T22:00:11.106201+00:00 0:00:02.756708 13258 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-03T22:00:05.621360+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-03T20:00:00+00:00 EmrJobFlowSensor 2021-04-03T21:21:26.076316+00:00 2021-04-03T21:31:28.954656+00:00 0:10:02.878340 13256 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T21:21:23.827025+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-03T20:00:00+00:00 EmrJobFlowSensor 2021-04-03T21:21:22.062817+00:00 2021-04-03T21:31:25.048731+00:00 0:10:02.985914 13255 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T21:21:19.822906+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-03T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T21:21:04.034842+00:00 2021-04-03T21:21:05.747460+00:00 0:00:01.712618 13254 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T21:21:01.809523+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-03T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T21:21:00.419978+00:00 2021-04-03T21:21:02.177448+00:00 0:00:01.757470 13253 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T21:20:57.870944+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-03T20:00:00+00:00 PythonOperator 2021-04-03T21:20:42.420815+00:00 2021-04-03T21:20:45.212663+00:00 0:00:02.791848 13252 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T21:20:39.847573+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-03T20:00:00+00:00 PythonOperator 2021-04-03T21:20:38.039753+00:00 2021-04-03T21:20:41.293287+00:00 0:00:03.253534 13251 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T21:20:35.790101+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-03T20:00:00+00:00 TriggerDagRunOperator 2021-04-03T21:20:18.290719+00:00 2021-04-03T21:20:18.806878+00:00 0:00:00.516159 13250 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T21:20:15.735328+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-03T20:00:00+00:00 TriggerDagRunOperator 2021-04-03T21:20:17.903870+00:00 2021-04-03T21:20:18.306565+00:00 0:00:00.402695 13249 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T21:20:15.735363+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-03T20:05:00+00:00 EmrJobFlowSensor 2021-04-03T21:06:02.727197+00:00 2021-04-03T21:15:05.347290+00:00 0:09:02.620093 13248 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T21:06:00.291064+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-03T20:05:00+00:00 EmrCreateJobFlowOperator 2021-04-03T21:05:42.546410+00:00 2021-04-03T21:05:44.287584+00:00 0:00:01.741174 13247 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T21:05:40.255485+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-03T20:05:00+00:00 PythonOperator 2021-04-03T21:05:20.275455+00:00 2021-04-03T21:05:22.973019+00:00 0:00:02.697564 13246 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T21:05:18.129358+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-03T20:00:00+00:00 EmrJobFlowSensor 2021-04-03T21:01:00.290843+00:00 2021-04-03T21:20:04.403914+00:00 0:19:04.113071 13245 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T21:00:57.810605+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-03T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T21:00:38.016905+00:00 2021-04-03T21:00:39.700219+00:00 0:00:01.683314 13244 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-03T21:00:35.788474+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-03T20:00:00+00:00 PythonOperator 2021-04-03T21:00:16.348911+00:00 2021-04-03T21:00:19.233348+00:00 0:00:02.884437 13243 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-03T21:00:13.765567+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-03T19:00:00+00:00 EmrJobFlowSensor 2021-04-03T20:11:19.051029+00:00 2021-04-03T20:21:21.830916+00:00 0:10:02.779887 13241 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T20:11:16.855386+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-03T19:00:00+00:00 EmrJobFlowSensor 2021-04-03T20:11:11.085701+00:00 2021-04-03T20:21:14.019250+00:00 0:10:02.933549 13240 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T20:11:08.841323+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-03T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T20:10:47.081492+00:00 2021-04-03T20:10:48.772298+00:00 0:00:01.690806 13239 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T20:10:44.822028+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-03T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T20:10:43.104072+00:00 2021-04-03T20:10:44.766368+00:00 0:00:01.662296 13238 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T20:10:40.821463+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-03T19:00:00+00:00 PythonOperator 2021-04-03T20:10:25.320008+00:00 2021-04-03T20:10:28.192047+00:00 0:00:02.872039 13237 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T20:10:22.803313+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-03T19:00:00+00:00 PythonOperator 2021-04-03T20:10:21.271679+00:00 2021-04-03T20:10:24.246219+00:00 0:00:02.974540 13236 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T20:10:18.857174+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-03T19:00:00+00:00 TriggerDagRunOperator 2021-04-03T20:10:13.217521+00:00 2021-04-03T20:10:13.735485+00:00 0:00:00.517964 13235 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T20:10:10.793946+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-03T19:00:00+00:00 TriggerDagRunOperator 2021-04-03T20:10:13.001688+00:00 2021-04-03T20:10:13.403277+00:00 0:00:00.401589 13234 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T20:10:10.793982+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-03T19:05:00+00:00 EmrJobFlowSensor 2021-04-03T20:06:04.661826+00:00 2021-04-03T20:15:07.141241+00:00 0:09:02.479415 13233 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T20:06:02.342656+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-03T19:05:00+00:00 EmrCreateJobFlowOperator 2021-04-03T20:05:42.515668+00:00 2021-04-03T20:05:44.234373+00:00 0:00:01.718705 13232 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T20:05:40.224927+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-03T19:05:00+00:00 PythonOperator 2021-04-03T20:05:20.481252+00:00 2021-04-03T20:05:23.308571+00:00 0:00:02.827319 13231 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T20:05:18.204470+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-03T19:00:00+00:00 EmrJobFlowSensor 2021-04-03T20:00:56.548535+00:00 2021-04-03T20:09:59.295034+00:00 0:09:02.746499 13230 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T20:00:53.871178+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-03T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T20:00:34.482917+00:00 2021-04-03T20:00:36.281035+00:00 0:00:01.798118 13229 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-03T20:00:31.791323+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-03T19:00:00+00:00 PythonOperator 2021-04-03T20:00:14.251404+00:00 2021-04-03T20:00:17.010797+00:00 0:00:02.759393 13228 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-03T20:00:11.753961+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-03T18:00:00+00:00 EmrJobFlowSensor 2021-04-03T19:25:58.370630+00:00 2021-04-03T19:25:59.870487+00:00 0:00:01.499857 13226 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T19:25:56.185850+00:00 3 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-03T18:00:00+00:00 EmrJobFlowSensor 2021-04-03T19:14:13.317366+00:00 2021-04-03T19:24:16.103966+00:00 0:10:02.786600 13224 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T19:14:11.050048+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-03T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T19:14:05.304371+00:00 2021-04-03T19:14:06.997502+00:00 0:00:01.693131 13223 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T19:14:03.038463+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-03T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T19:13:51.283673+00:00 2021-04-03T19:13:53.124897+00:00 0:00:01.841224 13222 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T19:13:49.046735+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-03T18:00:00+00:00 PythonOperator 2021-04-03T19:13:43.609877+00:00 2021-04-03T19:13:46.337178+00:00 0:00:02.727301 13221 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T19:13:41.144437+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-03T18:00:00+00:00 PythonOperator 2021-04-03T19:13:31.624512+00:00 2021-04-03T19:13:34.667271+00:00 0:00:03.042759 13220 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T19:13:29.077595+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-03T18:00:00+00:00 TriggerDagRunOperator 2021-04-03T19:13:23.396584+00:00 2021-04-03T19:13:24.261793+00:00 0:00:00.865209 13219 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T19:13:21.008463+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-03T18:00:00+00:00 TriggerDagRunOperator 2021-04-03T19:13:23.312018+00:00 2021-04-03T19:13:23.905107+00:00 0:00:00.593089 13218 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T19:13:21.008435+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-03T18:05:00+00:00 EmrJobFlowSensor 2021-04-03T19:05:52.601400+00:00 2021-04-03T19:14:55.245428+00:00 0:09:02.644028 13217 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T19:05:50.327809+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-03T18:05:00+00:00 EmrCreateJobFlowOperator 2021-04-03T19:05:30.979182+00:00 2021-04-03T19:05:32.640392+00:00 0:00:01.661210 13216 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T19:05:28.468691+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-03T18:05:00+00:00 PythonOperator 2021-04-03T19:05:10.597204+00:00 2021-04-03T19:05:13.259280+00:00 0:00:02.662076 13215 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T19:05:08.359258+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-03T18:00:00+00:00 EmrJobFlowSensor 2021-04-03T19:00:57.996930+00:00 2021-04-03T19:13:01.035803+00:00 0:12:03.038873 13214 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T19:00:55.797484+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-03T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T19:00:38.051052+00:00 2021-04-03T19:00:39.769397+00:00 0:00:01.718345 13213 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-03T19:00:35.748432+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-03T18:00:00+00:00 PythonOperator 2021-04-03T19:00:16.159958+00:00 2021-04-03T19:00:18.937735+00:00 0:00:02.777777 13212 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-03T19:00:13.725417+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-03T17:00:00+00:00 EmrJobFlowSensor 2021-04-03T18:10:37.306481+00:00 2021-04-03T18:19:39.961154+00:00 0:09:02.654673 13210 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T18:10:35.054333+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-03T17:00:00+00:00 EmrJobFlowSensor 2021-04-03T18:10:35.520526+00:00 2021-04-03T18:20:38.436771+00:00 0:10:02.916245 13209 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T18:10:32.980549+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-03T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T18:10:11.201428+00:00 2021-04-03T18:10:13.011753+00:00 0:00:01.810325 13208 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T18:10:08.952330+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-03T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T18:10:09.176977+00:00 2021-04-03T18:10:10.917082+00:00 0:00:01.740105 13207 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T18:10:06.950994+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-03T17:00:00+00:00 PythonOperator 2021-04-03T18:09:45.301408+00:00 2021-04-03T18:09:48.118644+00:00 0:00:02.817236 13206 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T18:09:42.905439+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-03T17:00:00+00:00 PythonOperator 2021-04-03T18:09:43.110297+00:00 2021-04-03T18:09:46.016154+00:00 0:00:02.905857 13205 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T18:09:40.904865+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-03T17:00:00+00:00 TriggerDagRunOperator 2021-04-03T18:09:25.459407+00:00 2021-04-03T18:09:25.989532+00:00 0:00:00.530125 13204 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T18:09:22.965669+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-03T17:00:00+00:00 TriggerDagRunOperator 2021-04-03T18:09:25.378641+00:00 2021-04-03T18:09:25.847213+00:00 0:00:00.468572 13203 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T18:09:22.965716+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-03T17:05:00+00:00 EmrJobFlowSensor 2021-04-03T18:05:52.712353+00:00 2021-04-03T18:14:55.283399+00:00 0:09:02.571046 13202 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T18:05:50.479117+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-03T17:05:00+00:00 EmrCreateJobFlowOperator 2021-04-03T18:05:32.649565+00:00 2021-04-03T18:05:34.316315+00:00 0:00:01.666750 13201 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T18:05:30.462632+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-03T17:05:00+00:00 PythonOperator 2021-04-03T18:05:10.589823+00:00 2021-04-03T18:05:13.354947+00:00 0:00:02.765124 13200 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T18:05:08.401030+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-03T17:00:00+00:00 EmrJobFlowSensor 2021-04-03T18:01:06.215726+00:00 2021-04-03T18:09:08.851714+00:00 0:08:02.635988 13199 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T18:01:03.913983+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-03T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T18:00:42.126831+00:00 2021-04-03T18:00:43.830751+00:00 0:00:01.703920 13198 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-03T18:00:39.891818+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-03T17:00:00+00:00 PythonOperator 2021-04-03T18:00:22.347269+00:00 2021-04-03T18:00:25.265077+00:00 0:00:02.917808 13197 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-03T18:00:19.874896+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-03T16:00:00+00:00 EmrJobFlowSensor 2021-04-03T17:11:40.351453+00:00 2021-04-03T17:20:43.053264+00:00 0:09:02.701811 13195 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T17:11:37.888756+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-03T16:00:00+00:00 EmrJobFlowSensor 2021-04-03T17:11:16.116633+00:00 2021-04-03T17:20:18.825329+00:00 0:09:02.708696 13194 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T17:11:13.821234+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-03T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T17:11:08.136510+00:00 2021-04-03T17:11:09.914876+00:00 0:00:01.778366 13193 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T17:11:05.814713+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-03T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T17:10:54.359027+00:00 2021-04-03T17:10:56.162365+00:00 0:00:01.803338 13192 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T17:10:51.857530+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-03T16:00:00+00:00 PythonOperator 2021-04-03T17:10:44.703155+00:00 2021-04-03T17:10:47.860925+00:00 0:00:03.157770 13191 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T17:10:41.857490+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-03T16:00:00+00:00 PythonOperator 2021-04-03T17:10:32.326842+00:00 2021-04-03T17:10:35.193924+00:00 0:00:02.867082 13190 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T17:10:29.866021+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-03T16:00:00+00:00 TriggerDagRunOperator 2021-04-03T17:10:18.221407+00:00 2021-04-03T17:10:18.738570+00:00 0:00:00.517163 13189 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T17:10:15.751338+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-03T16:00:00+00:00 TriggerDagRunOperator 2021-04-03T17:10:17.997355+00:00 2021-04-03T17:10:18.434058+00:00 0:00:00.436703 13188 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T17:10:15.751375+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-03T16:05:00+00:00 EmrJobFlowSensor 2021-04-03T17:06:03.595436+00:00 2021-04-03T17:14:06.212065+00:00 0:08:02.616629 13187 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T17:06:01.337994+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-03T16:05:00+00:00 EmrCreateJobFlowOperator 2021-04-03T17:05:37.580337+00:00 2021-04-03T17:05:39.230266+00:00 0:00:01.649929 13186 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T17:05:35.313977+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-03T16:05:00+00:00 PythonOperator 2021-04-03T17:05:15.810134+00:00 2021-04-03T17:05:18.526695+00:00 0:00:02.716561 13185 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T17:05:13.351740+00:00 2 default_pool