Task Instances

  State Dag Id Task Id Execution Date Operator Start Date End Date Duration Job Id Hostname Unixname Priority Weight Queue Queued Dttm Try Number Pool Log Url
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-05T00:00:00+00:00 TriggerDagRunOperator 2021-04-05T01:11:09.634646+00:00 2021-04-05T01:11:10.133887+00:00 0:00:00.499241 13671 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T01:11:07.186094+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-05T00:00:00+00:00 TriggerDagRunOperator 2021-04-05T01:11:09.399586+00:00 2021-04-05T01:11:09.824199+00:00 0:00:00.424613 13670 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T01:11:07.186059+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-05T00:05:00+00:00 EmrJobFlowSensor 2021-04-05T01:06:08.935823+00:00 2021-04-05T01:14:11.308844+00:00 0:08:02.373021 13669 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T01:06:06.695959+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-05T00:05:00+00:00 EmrCreateJobFlowOperator 2021-04-05T01:05:36.779551+00:00 2021-04-05T01:05:38.407789+00:00 0:00:01.628238 13668 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-05T01:05:34.611910+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-05T00:05:00+00:00 PythonOperator 2021-04-05T01:05:16.757209+00:00 2021-04-05T01:05:19.477253+00:00 0:00:02.720044 13667 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T01:05:14.599716+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-05T00:00:00+00:00 EmrJobFlowSensor 2021-04-05T01:00:46.438167+00:00 2021-04-05T01:10:49.276867+00:00 0:10:02.838700 13666 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T01:00:44.193817+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-05T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-05T01:00:24.657967+00:00 2021-04-05T01:00:26.518527+00:00 0:00:01.860560 13665 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-05T01:00:22.169579+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-05T00:00:00+00:00 PythonOperator 2021-04-05T01:00:04.623369+00:00 2021-04-05T01:00:07.359063+00:00 0:00:02.735694 13664 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-05T01:00:02.169415+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-04T23:00:00+00:00 EmrJobFlowSensor 2021-04-05T00:12:28.114776+00:00 2021-04-05T00:22:30.987899+00:00 0:10:02.873123 13662 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T00:12:25.730750+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-04T23:00:00+00:00 EmrJobFlowSensor 2021-04-05T00:12:19.902665+00:00 2021-04-05T00:20:22.435962+00:00 0:08:02.533297 13661 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T00:12:17.715060+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-04T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-05T00:12:03.917884+00:00 2021-04-05T00:12:05.613152+00:00 0:00:01.695268 13660 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-05T00:12:01.701058+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-04T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-05T00:11:56.193379+00:00 2021-04-05T00:11:57.889658+00:00 0:00:01.696279 13659 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-05T00:11:53.786830+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-04T23:00:00+00:00 PythonOperator 2021-04-05T00:11:42.019107+00:00 2021-04-05T00:11:45.052492+00:00 0:00:03.033385 13658 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T00:11:39.745396+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-04T23:00:00+00:00 PythonOperator 2021-04-05T00:11:35.993230+00:00 2021-04-05T00:11:38.767319+00:00 0:00:02.774089 13657 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T00:11:33.668481+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-04T23:00:00+00:00 TriggerDagRunOperator 2021-04-05T00:11:20.306813+00:00 2021-04-05T00:11:20.821137+00:00 0:00:00.514324 13656 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T00:11:17.659220+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-04T23:00:00+00:00 TriggerDagRunOperator 2021-04-05T00:11:20.120728+00:00 2021-04-05T00:11:20.551476+00:00 0:00:00.430748 13655 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T00:11:17.659254+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-04T23:05:00+00:00 EmrJobFlowSensor 2021-04-05T00:05:59.437385+00:00 2021-04-05T00:15:02.199197+00:00 0:09:02.761812 13654 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T00:05:57.076927+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-04T23:05:00+00:00 EmrCreateJobFlowOperator 2021-04-05T00:05:37.506958+00:00 2021-04-05T00:05:39.248024+00:00 0:00:01.741066 13653 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-05T00:05:35.043974+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-04T23:05:00+00:00 PythonOperator 2021-04-05T00:05:15.612363+00:00 2021-04-05T00:05:18.283121+00:00 0:00:02.670758 13652 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T00:05:13.059621+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-04T23:00:00+00:00 EmrJobFlowSensor 2021-04-05T00:01:04.823154+00:00 2021-04-05T00:11:07.804713+00:00 0:10:02.981559 13651 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T00:01:02.517701+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-04T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-05T00:00:43.121330+00:00 2021-04-05T00:00:44.925943+00:00 0:00:01.804613 13650 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-05T00:00:40.555023+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-04T23:00:00+00:00 PythonOperator 2021-04-05T00:00:20.814823+00:00 2021-04-05T00:00:23.663907+00:00 0:00:02.849084 13649 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-05T00:00:18.433254+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-04T22:00:00+00:00 EmrJobFlowSensor 2021-04-04T23:11:27.708656+00:00 2021-04-04T23:20:30.391381+00:00 0:09:02.682725 13647 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T23:11:25.115521+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-04T22:00:00+00:00 EmrJobFlowSensor 2021-04-04T23:11:27.541675+00:00 2021-04-04T23:21:30.320750+00:00 0:10:02.779075 13646 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T23:11:25.115553+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-04T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T23:11:05.781105+00:00 2021-04-04T23:11:07.608157+00:00 0:00:01.827052 13645 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T23:11:03.164029+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-04T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T23:11:05.661339+00:00 2021-04-04T23:11:07.370536+00:00 0:00:01.709197 13644 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T23:11:03.163983+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-04T22:00:00+00:00 PythonOperator 2021-04-04T23:10:43.551400+00:00 2021-04-04T23:10:46.652003+00:00 0:00:03.100603 13643 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T23:10:41.084022+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-04T22:00:00+00:00 PythonOperator 2021-04-04T23:10:43.389694+00:00 2021-04-04T23:10:46.160533+00:00 0:00:02.770839 13642 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T23:10:41.083975+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-04T22:00:00+00:00 TriggerDagRunOperator 2021-04-04T23:10:25.410134+00:00 2021-04-04T23:10:25.979409+00:00 0:00:00.569275 13641 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T23:10:23.053726+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-04T22:00:00+00:00 TriggerDagRunOperator 2021-04-04T23:10:25.366940+00:00 2021-04-04T23:10:25.853167+00:00 0:00:00.486227 13640 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T23:10:23.053759+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-04T22:05:00+00:00 EmrJobFlowSensor 2021-04-04T23:05:48.931266+00:00 2021-04-04T23:14:51.521210+00:00 0:09:02.589944 13639 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T23:05:46.655775+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-04T22:05:00+00:00 EmrCreateJobFlowOperator 2021-04-04T23:05:26.924915+00:00 2021-04-04T23:05:28.572492+00:00 0:00:01.647577 13638 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T23:05:24.663066+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-04T22:05:00+00:00 PythonOperator 2021-04-04T23:05:06.876930+00:00 2021-04-04T23:05:09.575264+00:00 0:00:02.698334 13637 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T23:05:04.649339+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-04T22:00:00+00:00 EmrJobFlowSensor 2021-04-04T23:01:04.478719+00:00 2021-04-04T23:10:07.251697+00:00 0:09:02.772978 13636 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T23:01:02.214196+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-04T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T23:00:42.355151+00:00 2021-04-04T23:00:44.215863+00:00 0:00:01.860712 13635 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-04T23:00:40.194167+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-04T22:00:00+00:00 PythonOperator 2021-04-04T23:00:22.482229+00:00 2021-04-04T23:00:25.213468+00:00 0:00:02.731239 13634 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-04T23:00:20.151178+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-04T21:00:00+00:00 EmrJobFlowSensor 2021-04-04T22:12:32.405545+00:00 2021-04-04T22:22:35.074068+00:00 0:10:02.668523 13632 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T22:12:30.211023+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-04T21:00:00+00:00 EmrJobFlowSensor 2021-04-04T22:12:18.694122+00:00 2021-04-04T22:21:21.521147+00:00 0:09:02.827025 13631 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T22:12:16.269761+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-04T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T22:12:10.397041+00:00 2021-04-04T22:12:12.115361+00:00 0:00:01.718320 13630 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T22:12:08.190400+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-04T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T22:11:48.400405+00:00 2021-04-04T22:11:50.158044+00:00 0:00:01.757639 13629 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T22:11:46.149082+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-04T21:00:00+00:00 PythonOperator 2021-04-04T22:11:40.372843+00:00 2021-04-04T22:11:43.322147+00:00 0:00:02.949304 13628 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T22:11:38.146227+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-04T21:00:00+00:00 PythonOperator 2021-04-04T22:11:24.387562+00:00 2021-04-04T22:11:27.287107+00:00 0:00:02.899545 13627 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T22:11:22.129605+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-04T21:00:00+00:00 TriggerDagRunOperator 2021-04-04T22:11:18.678171+00:00 2021-04-04T22:11:19.200840+00:00 0:00:00.522669 13626 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T22:11:16.126992+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-04T21:00:00+00:00 TriggerDagRunOperator 2021-04-04T22:11:18.516485+00:00 2021-04-04T22:11:18.968178+00:00 0:00:00.451693 13625 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T22:11:16.127041+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-04T21:05:00+00:00 EmrJobFlowSensor 2021-04-04T22:05:57.957202+00:00 2021-04-04T22:15:00.460779+00:00 0:09:02.503577 13624 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T22:05:55.722807+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-04T21:05:00+00:00 EmrCreateJobFlowOperator 2021-04-04T22:05:37.962629+00:00 2021-04-04T22:05:39.709101+00:00 0:00:01.746472 13623 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T22:05:35.708321+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-04T21:05:00+00:00 PythonOperator 2021-04-04T22:05:16.239119+00:00 2021-04-04T22:05:18.955548+00:00 0:00:02.716429 13622 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T22:05:13.689634+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-04T21:00:00+00:00 EmrJobFlowSensor 2021-04-04T22:01:01.313307+00:00 2021-04-04T22:11:04.141023+00:00 0:10:02.827716 13621 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T22:00:59.075103+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-04T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T22:00:39.478825+00:00 2021-04-04T22:00:41.316039+00:00 0:00:01.837214 13620 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-04T22:00:37.053868+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-04T21:00:00+00:00 PythonOperator 2021-04-04T22:00:17.283602+00:00 2021-04-04T22:00:20.029176+00:00 0:00:02.745574 13619 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-04T22:00:14.983290+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-04T20:00:00+00:00 EmrJobFlowSensor 2021-04-04T21:13:10.125886+00:00 2021-04-04T21:21:12.707153+00:00 0:08:02.581267 13617 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T21:13:07.667020+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-04T20:00:00+00:00 EmrJobFlowSensor 2021-04-04T21:12:53.865595+00:00 2021-04-04T21:21:56.576585+00:00 0:09:02.710990 13616 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T21:12:51.592396+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-04T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T21:12:48.176137+00:00 2021-04-04T21:12:49.864345+00:00 0:00:01.688208 13615 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T21:12:45.658314+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-04T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T21:12:31.794720+00:00 2021-04-04T21:12:33.625972+00:00 0:00:01.831252 13614 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T21:12:29.541371+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-04T20:00:00+00:00 PythonOperator 2021-04-04T21:12:27.894105+00:00 2021-04-04T21:12:30.573462+00:00 0:00:02.679357 13613 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T21:12:25.585004+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-04T20:00:00+00:00 PythonOperator 2021-04-04T21:12:11.845192+00:00 2021-04-04T21:12:14.861669+00:00 0:00:03.016477 13612 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T21:12:09.505249+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-04T20:00:00+00:00 TriggerDagRunOperator 2021-04-04T21:12:03.909185+00:00 2021-04-04T21:12:04.360508+00:00 0:00:00.451323 13611 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T21:12:01.545003+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-04T20:00:00+00:00 TriggerDagRunOperator 2021-04-04T21:12:03.874437+00:00 2021-04-04T21:12:04.467722+00:00 0:00:00.593285 13610 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T21:12:01.545031+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-04T20:05:00+00:00 EmrJobFlowSensor 2021-04-04T21:06:03.384071+00:00 2021-04-04T21:14:06.001622+00:00 0:08:02.617551 13609 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T21:06:01.044055+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-04T20:05:00+00:00 EmrCreateJobFlowOperator 2021-04-04T21:05:41.086481+00:00 2021-04-04T21:05:42.705680+00:00 0:00:01.619199 13608 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T21:05:38.861617+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-04T20:05:00+00:00 PythonOperator 2021-04-04T21:05:21.368427+00:00 2021-04-04T21:05:24.078497+00:00 0:00:02.710070 13607 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T21:05:18.745887+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-04T20:00:00+00:00 EmrJobFlowSensor 2021-04-04T21:00:52.535013+00:00 2021-04-04T21:11:55.491074+00:00 0:11:02.956061 13606 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T21:00:50.279068+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-04T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T21:00:30.766149+00:00 2021-04-04T21:00:32.495030+00:00 0:00:01.728881 13605 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-04T21:00:28.274211+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-04T20:00:00+00:00 PythonOperator 2021-04-04T21:00:09.149947+00:00 2021-04-04T21:00:11.920372+00:00 0:00:02.770425 13604 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-04T21:00:06.351982+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-04T19:00:00+00:00 EmrJobFlowSensor 2021-04-04T20:11:27.764914+00:00 2021-04-04T20:21:30.443661+00:00 0:10:02.678747 13602 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T20:11:25.608362+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-04T19:00:00+00:00 EmrJobFlowSensor 2021-04-04T20:11:21.835292+00:00 2021-04-04T20:29:25.843278+00:00 0:18:04.007986 13601 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T20:11:19.601482+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-04T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T20:11:05.836561+00:00 2021-04-04T20:11:07.551676+00:00 0:00:01.715115 13600 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T20:11:03.587594+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-04T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T20:11:00.115971+00:00 2021-04-04T20:11:02.026379+00:00 0:00:01.910408 13599 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T20:10:57.585422+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-04T19:00:00+00:00 PythonOperator 2021-04-04T20:10:45.809530+00:00 2021-04-04T20:10:48.840749+00:00 0:00:03.031219 13598 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T20:10:43.524750+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-04T19:00:00+00:00 PythonOperator 2021-04-04T20:10:39.804390+00:00 2021-04-04T20:10:42.603364+00:00 0:00:02.798974 13597 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T20:10:37.527796+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-04T19:00:00+00:00 TriggerDagRunOperator 2021-04-04T20:10:20.022393+00:00 2021-04-04T20:10:20.550485+00:00 0:00:00.528092 13596 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T20:10:17.515097+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-04T19:00:00+00:00 TriggerDagRunOperator 2021-04-04T20:10:19.805993+00:00 2021-04-04T20:10:20.227071+00:00 0:00:00.421078 13595 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T20:10:17.515145+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-04T19:05:00+00:00 EmrJobFlowSensor 2021-04-04T20:05:57.616966+00:00 2021-04-04T20:15:00.202660+00:00 0:09:02.585694 13594 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T20:05:55.152036+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-04T19:05:00+00:00 EmrCreateJobFlowOperator 2021-04-04T20:05:35.618496+00:00 2021-04-04T20:05:37.355856+00:00 0:00:01.737360 13593 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T20:05:33.083132+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-04T19:05:00+00:00 PythonOperator 2021-04-04T20:05:15.179397+00:00 2021-04-04T20:05:17.863037+00:00 0:00:02.683640 13592 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T20:05:12.960309+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-04T19:00:00+00:00 EmrJobFlowSensor 2021-04-04T20:00:56.888559+00:00 2021-04-04T20:09:59.656788+00:00 0:09:02.768229 13591 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T20:00:54.586874+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-04T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T20:00:36.790320+00:00 2021-04-04T20:00:38.586483+00:00 0:00:01.796163 13590 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-04T20:00:34.547146+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-04T19:00:00+00:00 PythonOperator 2021-04-04T20:00:06.971057+00:00 2021-04-04T20:00:09.835452+00:00 0:00:02.864395 13589 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-04T20:00:04.489758+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-04T18:00:00+00:00 EmrJobFlowSensor 2021-04-04T19:09:54.368984+00:00 2021-04-04T19:19:57.149692+00:00 0:10:02.780708 13587 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T19:09:52.012812+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-04T18:00:00+00:00 EmrJobFlowSensor 2021-04-04T19:09:48.545111+00:00 2021-04-04T19:19:51.297806+00:00 0:10:02.752695 13586 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T19:09:46.048601+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-04T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T19:09:32.447556+00:00 2021-04-04T19:09:34.128886+00:00 0:00:01.681330 13585 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T19:09:30.057941+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-04T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T19:09:28.225478+00:00 2021-04-04T19:09:29.913173+00:00 0:00:01.687695 13584 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T19:09:25.989161+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-04T18:00:00+00:00 PythonOperator 2021-04-04T19:09:10.402385+00:00 2021-04-04T19:09:13.120295+00:00 0:00:02.717910 13583 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T19:09:07.976819+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-04T18:00:00+00:00 PythonOperator 2021-04-04T19:09:06.199840+00:00 2021-04-04T19:09:09.501755+00:00 0:00:03.301915 13582 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T19:09:03.970494+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-04T18:00:00+00:00 TriggerDagRunOperator 2021-04-04T19:08:56.381784+00:00 2021-04-04T19:08:56.903701+00:00 0:00:00.521917 13581 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T19:08:53.966252+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-04T18:00:00+00:00 TriggerDagRunOperator 2021-04-04T19:08:56.216814+00:00 2021-04-04T19:08:56.643556+00:00 0:00:00.426742 13580 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T19:08:53.966219+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-04T18:05:00+00:00 EmrJobFlowSensor 2021-04-04T19:05:54.204551+00:00 2021-04-04T19:14:56.793458+00:00 0:09:02.588907 13579 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T19:05:51.759784+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-04T18:05:00+00:00 EmrCreateJobFlowOperator 2021-04-04T19:05:33.880078+00:00 2021-04-04T19:05:35.544899+00:00 0:00:01.664821 13578 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T19:05:31.687851+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-04T18:05:00+00:00 PythonOperator 2021-04-04T19:05:11.991466+00:00 2021-04-04T19:05:14.661719+00:00 0:00:02.670253 13577 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T19:05:09.610739+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-04T18:00:00+00:00 EmrJobFlowSensor 2021-04-04T19:00:47.419733+00:00 2021-04-04T19:08:50.061966+00:00 0:08:02.642233 13576 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T19:00:45.096458+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-04T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T19:00:25.566148+00:00 2021-04-04T19:00:27.369632+00:00 0:00:01.803484 13575 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-04T19:00:23.078742+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-04T18:00:00+00:00 PythonOperator 2021-04-04T19:00:05.660743+00:00 2021-04-04T19:00:08.542141+00:00 0:00:02.881398 13574 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-04T19:00:03.068260+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-04T17:00:00+00:00 EmrJobFlowSensor 2021-04-04T18:11:26.106914+00:00 2021-04-04T18:21:28.826147+00:00 0:10:02.719233 13572 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T18:11:23.672600+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-04T17:00:00+00:00 EmrJobFlowSensor 2021-04-04T18:11:10.063485+00:00 2021-04-04T18:30:14.190769+00:00 0:19:04.127284 13571 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T18:11:07.550128+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-04T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T18:11:05.925196+00:00 2021-04-04T18:11:07.767814+00:00 0:00:01.842618 13570 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T18:11:03.467926+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-04T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T18:10:49.898725+00:00 2021-04-04T18:10:51.686348+00:00 0:00:01.787623 13569 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T18:10:47.392347+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-04T17:00:00+00:00 PythonOperator 2021-04-04T18:10:41.621025+00:00 2021-04-04T18:10:44.538320+00:00 0:00:02.917295 13568 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T18:10:39.386487+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-04T17:00:00+00:00 PythonOperator 2021-04-04T18:10:27.707575+00:00 2021-04-04T18:10:30.483896+00:00 0:00:02.776321 13567 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T18:10:25.347111+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-04T17:00:00+00:00 TriggerDagRunOperator 2021-04-04T18:10:19.797439+00:00 2021-04-04T18:10:20.309092+00:00 0:00:00.511653 13566 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T18:10:17.344495+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-04T17:00:00+00:00 TriggerDagRunOperator 2021-04-04T18:10:19.588068+00:00 2021-04-04T18:10:20.018821+00:00 0:00:00.430753 13565 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T18:10:17.344465+00:00 2 default_pool