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 check_cluster_status 2021-04-14T20:00:00+00:00 EmrJobFlowSensor 2021-04-14T21:11:21.705561+00:00 2021-04-14T21:21:24.647345+00:00 0:10:02.941784 17233 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T21:11:19.500693+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-14T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-14T21:11:07.704657+00:00 2021-04-14T21:11:09.802166+00:00 0:00:02.097509 17232 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-14T21:11:05.486796+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-14T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-14T21:11:01.909750+00:00 2021-04-14T21:11:03.634641+00:00 0:00:01.724891 17231 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-14T21:10:59.556163+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-14T20:00:00+00:00 PythonOperator 2021-04-14T21:10:45.799845+00:00 2021-04-14T21:10:48.715083+00:00 0:00:02.915238 17230 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T21:10:43.446191+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-14T20:00:00+00:00 PythonOperator 2021-04-14T21:10:39.750848+00:00 2021-04-14T21:10:42.984746+00:00 0:00:03.233898 17229 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T21:10:37.439304+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-14T20:00:00+00:00 TriggerDagRunOperator 2021-04-14T21:10:25.722349+00:00 2021-04-14T21:10:26.139435+00:00 0:00:00.417086 17228 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T21:10:23.429785+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-14T20:00:00+00:00 TriggerDagRunOperator 2021-04-14T21:10:25.732103+00:00 2021-04-14T21:10:26.268892+00:00 0:00:00.536789 17227 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T21:10:23.429816+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-14T20:05:00+00:00 EmrJobFlowSensor 2021-04-14T21:05:59.182109+00:00 2021-04-14T21:15:01.906864+00:00 0:09:02.724755 17226 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T21:05:56.934209+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-14T20:05:00+00:00 EmrCreateJobFlowOperator 2021-04-14T21:05:37.100905+00:00 2021-04-14T21:05:38.779105+00:00 0:00:01.678200 17225 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-14T21:05:34.953007+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-14T20:05:00+00:00 PythonOperator 2021-04-14T21:05:17.173134+00:00 2021-04-14T21:05:19.996989+00:00 0:00:02.823855 17224 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T21:05:14.951059+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-14T20:00:00+00:00 EmrJobFlowSensor 2021-04-14T21:01:04.895840+00:00 2021-04-14T21:10:07.666238+00:00 0:09:02.770398 17223 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T21:01:02.510734+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-14T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-14T21:00:40.724562+00:00 2021-04-14T21:00:42.415855+00:00 0:00:01.691293 17222 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-14T21:00:38.486208+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-14T20:00:00+00:00 PythonOperator 2021-04-14T21:00:20.691901+00:00 2021-04-14T21:00:23.729483+00:00 0:00:03.037582 17221 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-14T21:00:18.425255+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-14T19:00:00+00:00 EmrJobFlowSensor 2021-04-14T20:10:26.061253+00:00 2021-04-14T20:19:28.779558+00:00 0:09:02.718305 17219 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T20:10:23.518033+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-14T19:00:00+00:00 EmrJobFlowSensor 2021-04-14T20:10:11.884395+00:00 2021-04-14T20:20:14.823378+00:00 0:10:02.938983 17218 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T20:10:09.568346+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-14T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-14T20:10:04.110218+00:00 2021-04-14T20:10:05.791879+00:00 0:00:01.681661 17217 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-14T20:10:01.499493+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-14T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-14T20:09:52.020405+00:00 2021-04-14T20:09:53.701134+00:00 0:00:01.680729 17216 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-14T20:09:49.485097+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-14T19:00:00+00:00 PythonOperator 2021-04-14T20:09:41.666112+00:00 2021-04-14T20:09:44.626009+00:00 0:00:02.959897 17215 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T20:09:39.450838+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-14T19:00:00+00:00 PythonOperator 2021-04-14T20:09:30.163647+00:00 2021-04-14T20:09:33.244534+00:00 0:00:03.080887 17214 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T20:09:27.483954+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-14T19:00:00+00:00 TriggerDagRunOperator 2021-04-14T20:09:17.646396+00:00 2021-04-14T20:09:18.159362+00:00 0:00:00.512966 17213 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T20:09:15.385950+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-14T19:00:00+00:00 TriggerDagRunOperator 2021-04-14T20:09:17.521101+00:00 2021-04-14T20:09:17.942570+00:00 0:00:00.421469 17212 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T20:09:15.385919+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-14T19:05:00+00:00 EmrJobFlowSensor 2021-04-14T20:05:57.261791+00:00 2021-04-14T20:14:59.933286+00:00 0:09:02.671495 17211 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T20:05:55.106734+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-14T19:05:00+00:00 EmrCreateJobFlowOperator 2021-04-14T20:05:29.207512+00:00 2021-04-14T20:05:30.880836+00:00 0:00:01.673324 17210 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-14T20:05:27.085364+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-14T19:05:00+00:00 PythonOperator 2021-04-14T20:05:07.245651+00:00 2021-04-14T20:05:10.065221+00:00 0:00:02.819570 17209 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T20:05:05.010881+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-14T19:00:00+00:00 EmrJobFlowSensor 2021-04-14T20:00:50.900530+00:00 2021-04-14T20:08:54.071399+00:00 0:08:03.170869 17208 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T20:00:48.697942+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-14T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-14T20:00:28.911650+00:00 2021-04-14T20:00:30.626581+00:00 0:00:01.714931 17207 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-14T20:00:26.641302+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-14T19:00:00+00:00 PythonOperator 2021-04-14T20:00:09.010002+00:00 2021-04-14T20:00:12.864819+00:00 0:00:03.854817 17206 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-14T20:00:06.161229+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-14T18:00:00+00:00 EmrJobFlowSensor 2021-04-14T19:11:19.557116+00:00 2021-04-14T19:21:22.311238+00:00 0:10:02.754122 17204 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T19:11:17.353653+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-14T18:00:00+00:00 EmrJobFlowSensor 2021-04-14T19:11:07.626554+00:00 2021-04-14T19:20:10.209928+00:00 0:09:02.583374 17203 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T19:11:05.338042+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-14T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-14T19:10:57.721952+00:00 2021-04-14T19:10:59.448909+00:00 0:00:01.726957 17202 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-14T19:10:55.331324+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-14T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-14T19:10:45.928968+00:00 2021-04-14T19:10:47.996647+00:00 0:00:02.067679 17201 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-14T19:10:43.314736+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-14T18:00:00+00:00 PythonOperator 2021-04-14T19:10:37.467003+00:00 2021-04-14T19:10:40.747917+00:00 0:00:03.280914 17200 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T19:10:35.307958+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-14T18:00:00+00:00 PythonOperator 2021-04-14T19:10:23.580310+00:00 2021-04-14T19:10:26.722198+00:00 0:00:03.141888 17199 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T19:10:21.298996+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-14T18:00:00+00:00 TriggerDagRunOperator 2021-04-14T19:10:13.853677+00:00 2021-04-14T19:10:14.790808+00:00 0:00:00.937131 17198 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T19:10:11.354929+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-14T18:00:00+00:00 TriggerDagRunOperator 2021-04-14T19:10:13.809479+00:00 2021-04-14T19:10:14.719785+00:00 0:00:00.910306 17197 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T19:10:11.354973+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-14T18:05:00+00:00 EmrJobFlowSensor 2021-04-14T19:05:46.856943+00:00 2021-04-14T19:14:49.515612+00:00 0:09:02.658669 17196 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T19:05:44.697308+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-14T18:05:00+00:00 EmrCreateJobFlowOperator 2021-04-14T19:05:25.095718+00:00 2021-04-14T19:05:26.798242+00:00 0:00:01.702524 17195 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-14T19:05:22.659705+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-14T18:05:00+00:00 PythonOperator 2021-04-14T19:05:04.919729+00:00 2021-04-14T19:05:07.824840+00:00 0:00:02.905111 17194 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T19:05:02.599395+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-14T18:00:00+00:00 EmrJobFlowSensor 2021-04-14T19:01:00.840422+00:00 2021-04-14T19:10:03.429065+00:00 0:09:02.588643 17193 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T19:00:58.356672+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-14T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-14T19:00:40.408835+00:00 2021-04-14T19:00:42.228759+00:00 0:00:01.819924 17192 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-14T19:00:38.215653+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-14T18:00:00+00:00 PythonOperator 2021-04-14T19:00:18.593671+00:00 2021-04-14T19:00:21.508330+00:00 0:00:02.914659 17191 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-14T19:00:16.200687+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-14T17:00:00+00:00 EmrJobFlowSensor 2021-04-14T18:10:24.724373+00:00 2021-04-14T18:20:27.334349+00:00 0:10:02.609976 17189 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T18:10:22.376915+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-14T17:00:00+00:00 EmrJobFlowSensor 2021-04-14T18:10:12.458366+00:00 2021-04-14T18:20:15.199814+00:00 0:10:02.741448 17188 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T18:10:10.293258+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-14T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-14T18:10:05.067688+00:00 2021-04-14T18:10:06.916494+00:00 0:00:01.848806 17187 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-14T18:10:02.290237+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-14T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-14T18:09:52.515750+00:00 2021-04-14T18:09:54.309646+00:00 0:00:01.793896 17186 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-14T18:09:50.263712+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-14T17:00:00+00:00 PythonOperator 2021-04-14T18:09:42.706104+00:00 2021-04-14T18:09:45.563391+00:00 0:00:02.857287 17185 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T18:09:40.254952+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-14T17:00:00+00:00 PythonOperator 2021-04-14T18:09:30.837190+00:00 2021-04-14T18:09:33.939625+00:00 0:00:03.102435 17184 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T18:09:28.340841+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-14T17:00:00+00:00 TriggerDagRunOperator 2021-04-14T18:09:24.481425+00:00 2021-04-14T18:09:24.911784+00:00 0:00:00.430359 17183 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T18:09:22.135411+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-14T17:00:00+00:00 TriggerDagRunOperator 2021-04-14T18:09:24.376820+00:00 2021-04-14T18:09:24.923243+00:00 0:00:00.546423 17182 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T18:09:22.135384+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-14T17:05:00+00:00 EmrJobFlowSensor 2021-04-14T18:05:54.195995+00:00 2021-04-14T18:14:56.858167+00:00 0:09:02.662172 17181 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T18:05:51.843453+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-14T17:05:00+00:00 EmrCreateJobFlowOperator 2021-04-14T18:05:32.055242+00:00 2021-04-14T18:05:33.839166+00:00 0:00:01.783924 17180 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-14T18:05:29.851876+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-14T17:05:00+00:00 PythonOperator 2021-04-14T18:05:11.921286+00:00 2021-04-14T18:05:14.819963+00:00 0:00:02.898677 17179 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T18:05:09.748640+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-14T17:00:00+00:00 EmrJobFlowSensor 2021-04-14T18:01:00.150488+00:00 2021-04-14T18:09:02.795789+00:00 0:08:02.645301 17178 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T18:00:57.645374+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-14T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-14T18:00:37.689895+00:00 2021-04-14T18:00:39.495981+00:00 0:00:01.806086 17177 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-14T18:00:35.487373+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-14T17:00:00+00:00 PythonOperator 2021-04-14T18:00:17.626346+00:00 2021-04-14T18:00:20.498299+00:00 0:00:02.871953 17176 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-14T18:00:15.419984+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-14T16:00:00+00:00 EmrJobFlowSensor 2021-04-14T17:13:13.047587+00:00 2021-04-14T17:22:15.712070+00:00 0:09:02.664483 17175 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T17:13:10.557579+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-14T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-14T17:12:52.944599+00:00 2021-04-14T17:12:54.603070+00:00 0:00:01.658471 17174 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-14T17:12:50.465799+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-14T16:00:00+00:00 PythonOperator 2021-04-14T17:12:30.604720+00:00 2021-04-14T17:12:33.485752+00:00 0:00:02.881032 17173 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T17:12:28.389386+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-14T16:00:00+00:00 EmrJobFlowSensor 2021-04-14T17:12:22.516914+00:00 2021-04-14T17:23:25.411556+00:00 0:11:02.894642 17172 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T17:12:20.368224+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-14T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-14T17:12:00.530715+00:00 2021-04-14T17:12:02.386725+00:00 0:00:01.856010 17171 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-14T17:11:58.348942+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-14T16:00:00+00:00 PythonOperator 2021-04-14T17:11:30.739055+00:00 2021-04-14T17:11:34.145267+00:00 0:00:03.406212 17170 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T17:11:28.353091+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-14T16:00:00+00:00 TriggerDagRunOperator 2021-04-14T17:11:25.120219+00:00 2021-04-14T17:11:25.554041+00:00 0:00:00.433822 17169 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T17:11:22.114376+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-14T16:00:00+00:00 TriggerDagRunOperator 2021-04-14T17:11:25.118552+00:00 2021-04-14T17:11:25.671480+00:00 0:00:00.552928 17168 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T17:11:22.114411+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-14T16:05:00+00:00 EmrJobFlowSensor 2021-04-14T17:05:51.979821+00:00 2021-04-14T17:14:54.548929+00:00 0:09:02.569108 17166 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T17:05:49.740844+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-14T16:05:00+00:00 EmrCreateJobFlowOperator 2021-04-14T17:05:30.133531+00:00 2021-04-14T17:05:31.861149+00:00 0:00:01.727618 17165 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-14T17:05:27.653662+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-14T16:05:00+00:00 PythonOperator 2021-04-14T17:05:09.862747+00:00 2021-04-14T17:05:13.100091+00:00 0:00:03.237344 17164 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T17:05:07.493495+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-14T16:00:00+00:00 EmrJobFlowSensor 2021-04-14T17:01:05.411099+00:00 2021-04-14T17:09:07.883837+00:00 0:08:02.472738 17163 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T17:01:03.104351+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-14T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-14T17:00:39.584591+00:00 2021-04-14T17:00:41.605177+00:00 0:00:02.020586 17162 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-14T17:00:37.082810+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-14T16:00:00+00:00 PythonOperator 2021-04-14T17:00:11.241907+00:00 2021-04-14T17:00:14.211992+00:00 0:00:02.970085 17161 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-14T17:00:08.997882+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-14T15:00:00+00:00 EmrJobFlowSensor 2021-04-14T16:18:29.571380+00:00 2021-04-14T16:28:33.151722+00:00 0:10:03.580342 17160 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T16:18:26.761616+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-14T15:00:00+00:00 EmrJobFlowSensor 2021-04-14T16:18:25.075710+00:00 2021-04-14T16:28:27.834851+00:00 0:10:02.759141 17159 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T16:18:22.751669+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-14T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-14T16:18:06.892664+00:00 2021-04-14T16:18:08.587992+00:00 0:00:01.695328 17158 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-14T16:18:04.754816+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-14T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-14T16:18:02.941296+00:00 2021-04-14T16:18:04.770059+00:00 0:00:01.828763 17157 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-14T16:18:00.606955+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-14T15:00:00+00:00 PythonOperator 2021-04-14T16:17:47.179539+00:00 2021-04-14T16:17:50.590866+00:00 0:00:03.411327 17156 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T16:17:44.652212+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-14T15:00:00+00:00 PythonOperator 2021-04-14T16:17:40.829840+00:00 2021-04-14T16:17:43.915022+00:00 0:00:03.085182 17155 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T16:17:38.486690+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-14T15:00:00+00:00 TriggerDagRunOperator 2021-04-14T16:17:32.836595+00:00 2021-04-14T16:17:33.235576+00:00 0:00:00.398981 17154 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T16:17:30.473164+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-14T15:00:00+00:00 TriggerDagRunOperator 2021-04-14T16:17:32.831432+00:00 2021-04-14T16:17:33.369905+00:00 0:00:00.538473 17153 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T16:17:30.473138+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-14T15:00:00+00:00 EmrJobFlowSensor 2021-04-14T16:08:26.000458+00:00 2021-04-14T16:17:28.661151+00:00 0:09:02.660693 17152 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T16:08:23.557752+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-14T15:05:00+00:00 EmrJobFlowSensor 2021-04-14T16:08:21.576396+00:00 2021-04-14T16:16:24.146889+00:00 0:08:02.570493 17151 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T16:08:19.484724+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-14T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-14T16:08:04.223606+00:00 2021-04-14T16:08:06.095109+00:00 0:00:01.871503 17150 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-14T16:08:01.487281+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-14T15:05:00+00:00 EmrCreateJobFlowOperator 2021-04-14T16:08:01.566611+00:00 2021-04-14T16:08:03.681169+00:00 0:00:02.114558 17149 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-14T16:07:59.443697+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-14T15:00:00+00:00 PythonOperator 2021-04-14T16:07:43.692033+00:00 2021-04-14T16:07:46.570259+00:00 0:00:02.878226 17148 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-14T16:07:41.469951+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-14T15:05:00+00:00 PythonOperator 2021-04-14T16:07:40.535617+00:00 2021-04-14T16:07:43.415865+00:00 0:00:02.880248 17147 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T16:07:37.409827+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-14T14:00:00+00:00 EmrJobFlowSensor 2021-04-14T15:12:02.167629+00:00 2021-04-14T15:21:04.753887+00:00 0:09:02.586258 17145 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T15:11:59.555583+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-14T14:00:00+00:00 EmrJobFlowSensor 2021-04-14T15:11:59.859813+00:00 2021-04-14T15:22:03.453180+00:00 0:10:03.593367 17144 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T15:11:57.440256+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-14T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-14T15:11:39.858206+00:00 2021-04-14T15:11:41.559373+00:00 0:00:01.701167 17143 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-14T15:11:37.415704+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-14T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-14T15:11:39.831971+00:00 2021-04-14T15:11:41.650857+00:00 0:00:01.818886 17142 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-14T15:11:37.415737+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-14T14:00:00+00:00 PythonOperator 2021-04-14T15:11:17.938166+00:00 2021-04-14T15:11:21.089312+00:00 0:00:03.151146 17141 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T15:11:15.459171+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-14T14:00:00+00:00 PythonOperator 2021-04-14T15:11:17.972086+00:00 2021-04-14T15:11:20.944942+00:00 0:00:02.972856 17140 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T15:11:15.459131+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-14T14:00:00+00:00 TriggerDagRunOperator 2021-04-14T15:10:55.780602+00:00 2021-04-14T15:10:56.827159+00:00 0:00:01.046557 17139 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T15:10:53.365626+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-14T14:00:00+00:00 TriggerDagRunOperator 2021-04-14T15:10:55.709460+00:00 2021-04-14T15:10:56.269655+00:00 0:00:00.560195 17138 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T15:10:53.365657+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-14T14:05:00+00:00 EmrJobFlowSensor 2021-04-14T15:05:55.174048+00:00 2021-04-14T15:14:57.659900+00:00 0:09:02.485852 17137 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T15:05:53.003734+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-14T14:05:00+00:00 EmrCreateJobFlowOperator 2021-04-14T15:05:33.359655+00:00 2021-04-14T15:05:35.074429+00:00 0:00:01.714774 17136 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-14T15:05:31.059361+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-14T14:05:00+00:00 PythonOperator 2021-04-14T15:05:11.175545+00:00 2021-04-14T15:05:14.104943+00:00 0:00:02.929398 17135 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T15:05:08.978472+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-14T14:00:00+00:00 EmrJobFlowSensor 2021-04-14T15:00:48.951056+00:00 2021-04-14T15:10:51.829950+00:00 0:10:02.878894 17134 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T15:00:46.557542+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-14T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-14T15:00:29.052899+00:00 2021-04-14T15:00:31.091224+00:00 0:00:02.038325 17133 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-14T15:00:26.462842+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-14T14:00:00+00:00 PythonOperator 2021-04-14T15:00:06.588940+00:00 2021-04-14T15:00:09.514557+00:00 0:00:02.925617 17132 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-14T15:00:04.389112+00:00 2 default_pool
success primary-audience-global-ind_v003 create_cluster 2021-04-14T14:18:27.297278+00:00 PythonOperator 2021-04-14T14:19:14.640749+00:00 2021-04-14T14:19:18.361596+00:00 0:00:03.720847 17131 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T14:19:12.167343+00:00 2 default_pool
success primary-audience-global-ind_v003 validation 2021-04-14T14:18:27.297278+00:00 PythonOperator 2021-04-14T14:18:52.476529+00:00 2021-04-14T14:18:52.824446+00:00 0:00:00.347917 17130 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-14T14:18:50.169867+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-14T13:00:00+00:00 EmrJobFlowSensor 2021-04-14T14:15:30.552151+00:00 2021-04-14T14:24:33.266376+00:00 0:09:02.714225 17129 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T14:15:27.950070+00:00 2 default_pool