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-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
success booking-processing-job_v002 check_cluster_status 2021-04-14T13:00:00+00:00 EmrJobFlowSensor 2021-04-14T14:15:14.091063+00:00 2021-04-14T14:25:17.069912+00:00 0:10:02.978849 17128 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T14:15:11.749480+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-14T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-14T14:15:10.090664+00:00 2021-04-14T14:15:11.799446+00:00 0:00:01.708782 17127 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-14T14:15:07.781784+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-14T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-14T14:14:51.845702+00:00 2021-04-14T14:14:53.542574+00:00 0:00:01.696872 17126 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-14T14:14:49.687619+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-14T13:00:00+00:00 PythonOperator 2021-04-14T14:14:45.891677+00:00 2021-04-14T14:14:48.869893+00:00 0:00:02.978216 17125 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T14:14:43.678586+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-14T13:00:00+00:00 PythonOperator 2021-04-14T14:14:31.879078+00:00 2021-04-14T14:14:35.080868+00:00 0:00:03.201790 17124 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T14:14:29.668336+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-14T13:00:00+00:00 TriggerDagRunOperator 2021-04-14T14:14:26.289048+00:00 2021-04-14T14:14:26.752243+00:00 0:00:00.463195 17123 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T14:14:23.665588+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-14T13:00:00+00:00 TriggerDagRunOperator 2021-04-14T14:14:26.319446+00:00 2021-04-14T14:14:26.887547+00:00 0:00:00.568101 17122 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T14:14:23.665554+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-14T13:05:00+00:00 EmrJobFlowSensor 2021-04-14T14:06:03.311192+00:00 2021-04-14T14:15:05.802091+00:00 0:09:02.490899 17120 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T14:06:00.989907+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-14T13:05:00+00:00 EmrCreateJobFlowOperator 2021-04-14T14:05:41.247539+00:00 2021-04-14T14:05:42.866235+00:00 0:00:01.618696 17119 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-14T14:05:38.960421+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-14T13:05:00+00:00 PythonOperator 2021-04-14T14:05:20.999624+00:00 2021-04-14T14:05:24.212339+00:00 0:00:03.212715 17118 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T14:05:18.855119+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-14T13:00:00+00:00 EmrJobFlowSensor 2021-04-14T14:01:14.703121+00:00 2021-04-14T14:10:17.439504+00:00 0:09:02.736383 17117 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T14:01:12.394269+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-14T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-14T14:00:42.590723+00:00 2021-04-14T14:00:44.321868+00:00 0:00:01.731145 17116 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-14T14:00:40.343885+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-14T13:00:00+00:00 PythonOperator 2021-04-14T14:00:14.674168+00:00 2021-04-14T14:00:17.597375+00:00 0:00:02.923207 17115 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-14T14:00:12.322854+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-14T12:00:00+00:00 EmrJobFlowSensor 2021-04-14T13:12:07.115643+00:00 2021-04-14T13:21:09.789288+00:00 0:09:02.673645 17114 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T13:12:04.953584+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-14T12:00:00+00:00 EmrJobFlowSensor 2021-04-14T13:11:47.598167+00:00 2021-04-14T13:20:50.358708+00:00 0:09:02.760541 17113 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T13:11:44.971437+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-14T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-14T13:11:43.908082+00:00 2021-04-14T13:11:45.763045+00:00 0:00:01.854963 17112 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-14T13:11:40.970760+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-14T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-14T13:11:25.663059+00:00 2021-04-14T13:11:27.338524+00:00 0:00:01.675465 17111 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-14T13:11:22.955408+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-14T12:00:00+00:00 PythonOperator 2021-04-14T13:11:23.336761+00:00 2021-04-14T13:11:27.097474+00:00 0:00:03.760713 17110 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T13:11:20.962122+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-14T12:00:00+00:00 PythonOperator 2021-04-14T13:11:03.170480+00:00 2021-04-14T13:11:06.133483+00:00 0:00:02.963003 17109 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T13:11:00.875379+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-14T12:00:00+00:00 TriggerDagRunOperator 2021-04-14T13:10:59.310646+00:00 2021-04-14T13:10:59.743423+00:00 0:00:00.432777 17108 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T13:10:56.858116+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-14T12:00:00+00:00 TriggerDagRunOperator 2021-04-14T13:10:59.298818+00:00 2021-04-14T13:10:59.850448+00:00 0:00:00.551630 17107 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T13:10:56.858165+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-14T12:05:00+00:00 EmrJobFlowSensor 2021-04-14T13:09:40.875284+00:00 2021-04-14T13:18:43.409491+00:00 0:09:02.534207 17106 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T13:09:38.694165+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-14T12:05:00+00:00 EmrCreateJobFlowOperator 2021-04-14T13:09:20.857860+00:00 2021-04-14T13:09:22.667647+00:00 0:00:01.809787 17105 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-14T13:09:18.652683+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-14T12:05:00+00:00 PythonOperator 2021-04-14T13:08:59.295758+00:00 2021-04-14T13:09:02.136706+00:00 0:00:02.840948 17104 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T13:08:56.629111+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-14T12:00:00+00:00 EmrJobFlowSensor 2021-04-14T13:00:49.304715+00:00 2021-04-14T13:10:52.113074+00:00 0:10:02.808359 17102 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T13:00:47.126272+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-14T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-14T13:00:27.399579+00:00 2021-04-14T13:00:29.122222+00:00 0:00:01.722643 17101 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-14T13:00:25.106062+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-14T12:00:00+00:00 PythonOperator 2021-04-14T13:00:05.500686+00:00 2021-04-14T13:00:08.383325+00:00 0:00:02.882639 17100 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-14T13:00:03.148311+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-14T11:00:00+00:00 EmrJobFlowSensor 2021-04-14T12:14:56.839325+00:00 2021-04-14T12:24:59.507973+00:00 0:10:02.668648 17099 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T12:14:54.604548+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-14T11:00:00+00:00 EmrJobFlowSensor 2021-04-14T12:14:52.989635+00:00 2021-04-14T12:24:55.636709+00:00 0:10:02.647074 17098 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T12:14:50.601196+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-14T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-14T12:14:34.838346+00:00 2021-04-14T12:14:36.672953+00:00 0:00:01.834607 17097 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-14T12:14:32.596272+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-14T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-14T12:14:31.014968+00:00 2021-04-14T12:14:32.697320+00:00 0:00:01.682352 17096 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-14T12:14:28.646418+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-14T11:00:00+00:00 PythonOperator 2021-04-14T12:14:12.732136+00:00 2021-04-14T12:14:16.107028+00:00 0:00:03.374892 17095 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T12:14:10.519010+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-14T11:00:00+00:00 PythonOperator 2021-04-14T12:14:10.785699+00:00 2021-04-14T12:14:13.700028+00:00 0:00:02.914329 17094 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T12:14:08.517859+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-14T11:00:00+00:00 TriggerDagRunOperator 2021-04-14T12:13:56.882581+00:00 2021-04-14T12:13:57.392253+00:00 0:00:00.509672 17093 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T12:13:54.504259+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-14T11:00:00+00:00 TriggerDagRunOperator 2021-04-14T12:13:56.765815+00:00 2021-04-14T12:13:57.161815+00:00 0:00:00.396000 17092 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T12:13:54.504231+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-14T11:00:00+00:00 EmrJobFlowSensor 2021-04-14T12:05:48.104502+00:00 2021-04-14T12:13:50.649654+00:00 0:08:02.545152 17091 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T12:05:45.719076+00:00 2 default_pool