Task Instances

Reset Filters
  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 create_cluster_and_add_emr_steps 2021-03-24T11:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T12:00:28.088527+00:00 2021-03-24T12:00:29.772355+00:00 0:00:01.683828 11233 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-24T12:00:25.790234+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-24T11:00:00+00:00 PythonOperator 2021-03-24T12:00:08.083656+00:00 2021-03-24T12:00:10.814935+00:00 0:00:02.731279 11232 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-24T12:00:05.738111+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-24T10:00:00+00:00 EmrJobFlowSensor 2021-03-24T11:11:39.103995+00:00 2021-03-24T11:21:41.781652+00:00 0:10:02.677657 11230 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T11:11:36.773501+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-24T10:00:00+00:00 EmrJobFlowSensor 2021-03-24T11:11:35.033510+00:00 2021-03-24T11:21:37.922879+00:00 0:10:02.889369 11229 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T11:11:32.711366+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-24T10:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T11:11:16.988437+00:00 2021-03-24T11:11:18.907678+00:00 0:00:01.919241 11228 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T11:11:14.743393+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-24T10:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T11:11:12.954924+00:00 2021-03-24T11:11:14.691451+00:00 0:00:01.736527 11227 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T11:11:10.689095+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-24T10:00:00+00:00 PythonOperator 2021-03-24T11:10:45.214490+00:00 2021-03-24T11:10:47.942717+00:00 0:00:02.728227 11226 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T11:10:42.595224+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-24T10:00:00+00:00 PythonOperator 2021-03-24T11:10:40.825614+00:00 2021-03-24T11:10:43.937767+00:00 0:00:03.112153 11225 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T11:10:38.596065+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-24T10:00:00+00:00 TriggerDagRunOperator 2021-03-24T11:10:35.157555+00:00 2021-03-24T11:10:35.685506+00:00 0:00:00.527951 11224 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T11:10:32.596782+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-24T10:00:00+00:00 TriggerDagRunOperator 2021-03-24T11:10:35.102626+00:00 2021-03-24T11:10:35.542393+00:00 0:00:00.439767 11223 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T11:10:32.596814+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-24T10:05:00+00:00 EmrJobFlowSensor 2021-03-24T11:06:04.675058+00:00 2021-03-24T11:15:07.294715+00:00 0:09:02.619657 11222 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T11:06:02.241350+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-24T10:05:00+00:00 EmrCreateJobFlowOperator 2021-03-24T11:05:42.315346+00:00 2021-03-24T11:05:44.040482+00:00 0:00:01.725136 11221 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T11:05:40.181619+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-24T10:05:00+00:00 PythonOperator 2021-03-24T11:05:20.380244+00:00 2021-03-24T11:05:23.173657+00:00 0:00:02.793413 11220 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T11:05:18.145933+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-24T10:00:00+00:00 EmrJobFlowSensor 2021-03-24T11:01:18.295013+00:00 2021-03-24T11:10:21.186474+00:00 0:09:02.891461 11219 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T11:01:15.862674+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-24T10:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T11:00:55.908065+00:00 2021-03-24T11:00:57.607175+00:00 0:00:01.699110 11218 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-24T11:00:53.736226+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-24T10:00:00+00:00 PythonOperator 2021-03-24T11:00:26.385783+00:00 2021-03-24T11:00:29.257746+00:00 0:00:02.871963 11217 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-24T11:00:23.728064+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-24T09:00:00+00:00 EmrJobFlowSensor 2021-03-24T10:11:23.973967+00:00 2021-03-24T10:20:26.644434+00:00 0:09:02.670467 11215 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T10:11:21.689388+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-24T09:00:00+00:00 EmrJobFlowSensor 2021-03-24T10:11:17.900012+00:00 2021-03-24T10:20:20.681301+00:00 0:09:02.781289 11214 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T10:11:15.687857+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-24T09:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T10:11:03.895294+00:00 2021-03-24T10:11:05.708349+00:00 0:00:01.813055 11213 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T10:11:01.672147+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-24T09:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T10:10:57.889486+00:00 2021-03-24T10:10:59.647619+00:00 0:00:01.758133 11212 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T10:10:55.669375+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-24T09:00:00+00:00 PythonOperator 2021-03-24T10:10:41.796935+00:00 2021-03-24T10:10:44.810060+00:00 0:00:03.013125 11211 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T10:10:39.653905+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-24T09:00:00+00:00 PythonOperator 2021-03-24T10:10:28.005213+00:00 2021-03-24T10:10:30.840903+00:00 0:00:02.835690 11210 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T10:10:25.649566+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-24T09:00:00+00:00 TriggerDagRunOperator 2021-03-24T10:10:13.965165+00:00 2021-03-24T10:10:14.498750+00:00 0:00:00.533585 11209 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T10:10:11.631480+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-24T09:00:00+00:00 TriggerDagRunOperator 2021-03-24T10:10:13.959410+00:00 2021-03-24T10:10:14.414180+00:00 0:00:00.454770 11208 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T10:10:11.631451+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-24T09:05:00+00:00 EmrJobFlowSensor 2021-03-24T10:06:07.500840+00:00 2021-03-24T10:14:10.039183+00:00 0:08:02.538343 11207 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T10:06:05.143267+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-24T09:05:00+00:00 EmrCreateJobFlowOperator 2021-03-24T10:05:45.329093+00:00 2021-03-24T10:05:46.944756+00:00 0:00:01.615663 11206 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T10:05:43.044242+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-24T09:05:00+00:00 PythonOperator 2021-03-24T10:05:25.117086+00:00 2021-03-24T10:05:27.809820+00:00 0:00:02.692734 11205 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T10:05:22.955947+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-24T09:00:00+00:00 EmrJobFlowSensor 2021-03-24T10:00:50.606476+00:00 2021-03-24T10:09:53.176774+00:00 0:09:02.570298 11204 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T10:00:48.441017+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-24T09:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T10:00:30.917730+00:00 2021-03-24T10:00:32.615047+00:00 0:00:01.697317 11203 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-24T10:00:28.482179+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-24T09:00:00+00:00 PythonOperator 2021-03-24T10:00:08.795350+00:00 2021-03-24T10:00:11.623989+00:00 0:00:02.828639 11202 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-24T10:00:06.389438+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-24T08:00:00+00:00 EmrJobFlowSensor 2021-03-24T09:12:28.931855+00:00 2021-03-24T09:21:31.476258+00:00 0:09:02.544403 11200 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T09:12:26.459025+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-24T08:00:00+00:00 EmrJobFlowSensor 2021-03-24T09:12:12.744204+00:00 2021-03-24T09:21:15.489538+00:00 0:09:02.745334 11199 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T09:12:10.397079+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-24T08:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T09:12:08.910010+00:00 2021-03-24T09:12:10.713706+00:00 0:00:01.803696 11198 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T09:12:06.460112+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-24T08:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T09:11:50.490115+00:00 2021-03-24T09:11:52.187103+00:00 0:00:01.696988 11197 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T09:11:48.332604+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-24T08:00:00+00:00 PythonOperator 2021-03-24T09:11:36.769487+00:00 2021-03-24T09:11:39.457397+00:00 0:00:02.687910 11196 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T09:11:34.322864+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-24T08:00:00+00:00 PythonOperator 2021-03-24T09:11:24.611038+00:00 2021-03-24T09:11:27.570498+00:00 0:00:02.959460 11195 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T09:11:22.324192+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-24T08:00:00+00:00 TriggerDagRunOperator 2021-03-24T09:11:18.598499+00:00 2021-03-24T09:11:19.018245+00:00 0:00:00.419746 11194 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T09:11:16.302638+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-24T08:00:00+00:00 TriggerDagRunOperator 2021-03-24T09:11:18.531044+00:00 2021-03-24T09:11:19.041488+00:00 0:00:00.510444 11193 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T09:11:16.302586+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-24T08:05:00+00:00 EmrJobFlowSensor 2021-03-24T09:06:05.962774+00:00 2021-03-24T09:16:08.701095+00:00 0:10:02.738321 11192 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T09:06:03.635645+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-24T08:05:00+00:00 EmrCreateJobFlowOperator 2021-03-24T09:05:45.690581+00:00 2021-03-24T09:05:47.405186+00:00 0:00:01.714605 11191 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T09:05:43.522062+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-24T08:05:00+00:00 PythonOperator 2021-03-24T09:05:23.855570+00:00 2021-03-24T09:05:26.689208+00:00 0:00:02.833638 11190 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T09:05:21.504040+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-24T08:00:00+00:00 EmrJobFlowSensor 2021-03-24T09:00:55.130767+00:00 2021-03-24T09:10:57.783478+00:00 0:10:02.652711 11189 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T09:00:52.902688+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-24T08:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T09:00:33.310815+00:00 2021-03-24T09:00:35.106140+00:00 0:00:01.795325 11188 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-24T09:00:30.950081+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-24T08:00:00+00:00 PythonOperator 2021-03-24T09:00:11.624755+00:00 2021-03-24T09:00:14.405301+00:00 0:00:02.780546 11187 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-24T09:00:08.789147+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-24T07:00:00+00:00 EmrJobFlowSensor 2021-03-24T08:11:10.014225+00:00 2021-03-24T08:20:12.712158+00:00 0:09:02.697933 11185 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T08:11:07.723284+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-24T07:00:00+00:00 EmrJobFlowSensor 2021-03-24T08:11:03.877483+00:00 2021-03-24T08:19:06.342394+00:00 0:08:02.464911 11184 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T08:11:01.726420+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-24T07:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T08:10:46.196589+00:00 2021-03-24T08:10:47.982700+00:00 0:00:01.786111 11183 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T08:10:43.707879+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-24T07:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T08:10:42.191941+00:00 2021-03-24T08:10:44.068483+00:00 0:00:01.876542 11182 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T08:10:39.766215+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-24T07:00:00+00:00 PythonOperator 2021-03-24T08:10:26.232697+00:00 2021-03-24T08:10:29.128485+00:00 0:00:02.895788 11181 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T08:10:23.759194+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-24T07:00:00+00:00 PythonOperator 2021-03-24T08:10:21.824484+00:00 2021-03-24T08:10:24.642776+00:00 0:00:02.818292 11180 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T08:10:19.684107+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-24T07:00:00+00:00 TriggerDagRunOperator 2021-03-24T08:10:08.155217+00:00 2021-03-24T08:10:08.594584+00:00 0:00:00.439367 11179 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T08:10:05.623073+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-24T07:00:00+00:00 TriggerDagRunOperator 2021-03-24T08:10:07.904770+00:00 2021-03-24T08:10:08.461302+00:00 0:00:00.556532 11178 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T08:10:05.623045+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-24T07:05:00+00:00 EmrJobFlowSensor 2021-03-24T08:05:51.308153+00:00 2021-03-24T08:13:53.713162+00:00 0:08:02.405009 11177 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T08:05:49.160618+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-24T07:05:00+00:00 EmrCreateJobFlowOperator 2021-03-24T08:05:31.637411+00:00 2021-03-24T08:05:33.289917+00:00 0:00:01.652506 11176 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T08:05:29.160580+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-24T07:05:00+00:00 PythonOperator 2021-03-24T08:05:09.552301+00:00 2021-03-24T08:05:12.262043+00:00 0:00:02.709742 11175 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T08:05:07.087851+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-24T07:00:00+00:00 EmrJobFlowSensor 2021-03-24T08:00:59.019118+00:00 2021-03-24T08:10:01.650128+00:00 0:09:02.631010 11174 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T08:00:56.424252+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-24T07:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T08:00:36.957400+00:00 2021-03-24T08:00:38.772637+00:00 0:00:01.815237 11173 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-24T08:00:34.474957+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-24T07:00:00+00:00 PythonOperator 2021-03-24T08:00:15.159478+00:00 2021-03-24T08:00:18.032593+00:00 0:00:02.873115 11172 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-24T08:00:12.388039+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-24T06:00:00+00:00 EmrJobFlowSensor 2021-03-24T07:11:23.859214+00:00 2021-03-24T07:20:26.630766+00:00 0:09:02.771552 11170 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T07:11:20.966912+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-24T06:00:00+00:00 EmrJobFlowSensor 2021-03-24T07:11:21.653821+00:00 2021-03-24T07:21:24.857819+00:00 0:10:03.203998 11169 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T07:11:19.069585+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-24T06:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T07:11:01.663919+00:00 2021-03-24T07:11:03.445492+00:00 0:00:01.781573 11168 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T07:10:58.852991+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-24T06:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T07:10:59.258057+00:00 2021-03-24T07:11:01.235454+00:00 0:00:01.977397 11167 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T07:10:56.778142+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-24T06:00:00+00:00 PythonOperator 2021-03-24T07:10:39.143966+00:00 2021-03-24T07:10:42.146330+00:00 0:00:03.002364 11166 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T07:10:36.691676+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-24T06:00:00+00:00 PythonOperator 2021-03-24T07:10:39.044136+00:00 2021-03-24T07:10:41.857911+00:00 0:00:02.813775 11165 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T07:10:36.691645+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-24T06:00:00+00:00 TriggerDagRunOperator 2021-03-24T07:10:31.297190+00:00 2021-03-24T07:10:31.720742+00:00 0:00:00.423552 11164 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T07:10:28.576717+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-24T06:00:00+00:00 TriggerDagRunOperator 2021-03-24T07:10:31.296917+00:00 2021-03-24T07:10:31.833196+00:00 0:00:00.536279 11163 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T07:10:28.576673+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-24T06:05:00+00:00 EmrJobFlowSensor 2021-03-24T07:05:50.069478+00:00 2021-03-24T07:13:52.349931+00:00 0:08:02.280453 11162 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T07:05:47.927733+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-24T06:05:00+00:00 EmrCreateJobFlowOperator 2021-03-24T07:05:30.278341+00:00 2021-03-24T07:05:32.083649+00:00 0:00:01.805308 11161 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T07:05:27.910501+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-24T06:05:00+00:00 PythonOperator 2021-03-24T07:05:08.202477+00:00 2021-03-24T07:05:10.867097+00:00 0:00:02.664620 11160 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T07:05:05.889484+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-24T06:00:00+00:00 EmrJobFlowSensor 2021-03-24T07:01:03.750242+00:00 2021-03-24T07:10:06.620989+00:00 0:09:02.870747 11159 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T07:01:01.459384+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-24T06:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T07:00:41.607449+00:00 2021-03-24T07:00:43.337219+00:00 0:00:01.729770 11158 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-24T07:00:39.418209+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-24T06:00:00+00:00 PythonOperator 2021-03-24T07:00:20.001439+00:00 2021-03-24T07:00:22.745514+00:00 0:00:02.744075 11157 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-24T07:00:17.476587+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-24T05:00:00+00:00 EmrJobFlowSensor 2021-03-24T06:12:41.583824+00:00 2021-03-24T06:21:44.218820+00:00 0:09:02.634996 11155 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T06:12:39.253802+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-24T05:00:00+00:00 EmrJobFlowSensor 2021-03-24T06:12:35.609906+00:00 2021-03-24T06:21:38.179265+00:00 0:09:02.569359 11154 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T06:12:33.187948+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-24T05:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T06:12:19.467917+00:00 2021-03-24T06:12:21.165069+00:00 0:00:01.697152 11153 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T06:12:17.151285+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-24T05:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T06:12:15.633149+00:00 2021-03-24T06:12:17.362792+00:00 0:00:01.729643 11152 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T06:12:13.172516+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-24T05:00:00+00:00 PythonOperator 2021-03-24T06:11:59.312839+00:00 2021-03-24T06:12:02.336921+00:00 0:00:03.024082 11151 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T06:11:57.073784+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-24T05:00:00+00:00 PythonOperator 2021-03-24T06:11:53.337811+00:00 2021-03-24T06:11:56.071503+00:00 0:00:02.733692 11150 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T06:11:51.064602+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-24T05:00:00+00:00 TriggerDagRunOperator 2021-03-24T06:11:37.366338+00:00 2021-03-24T06:11:37.811644+00:00 0:00:00.445306 11149 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T06:11:35.051217+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-24T05:00:00+00:00 TriggerDagRunOperator 2021-03-24T06:11:37.382164+00:00 2021-03-24T06:11:37.947620+00:00 0:00:00.565456 11148 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T06:11:35.051254+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-24T05:05:00+00:00 EmrJobFlowSensor 2021-03-24T06:05:56.601970+00:00 2021-03-24T06:14:59.085441+00:00 0:09:02.483471 11147 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T06:05:54.436072+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-24T05:05:00+00:00 EmrCreateJobFlowOperator 2021-03-24T06:05:34.903848+00:00 2021-03-24T06:05:36.530750+00:00 0:00:01.626902 11146 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T06:05:32.411375+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-24T05:05:00+00:00 PythonOperator 2021-03-24T06:05:12.674974+00:00 2021-03-24T06:05:15.478461+00:00 0:00:02.803487 11145 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T06:05:10.395567+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-24T05:00:00+00:00 EmrJobFlowSensor 2021-03-24T06:01:16.273405+00:00 2021-03-24T06:11:19.031568+00:00 0:10:02.758163 11144 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T06:01:14.023723+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-24T05:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T06:00:52.283741+00:00 2021-03-24T06:00:54.080246+00:00 0:00:01.796505 11143 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-24T06:00:49.998199+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-24T05:00:00+00:00 PythonOperator 2021-03-24T06:00:18.407846+00:00 2021-03-24T06:00:21.146727+00:00 0:00:02.738881 11142 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-24T06:00:15.972374+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-24T04:00:00+00:00 EmrJobFlowSensor 2021-03-24T05:11:37.820708+00:00 2021-03-24T05:20:40.590569+00:00 0:09:02.769861 11140 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T05:11:35.599224+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-24T04:00:00+00:00 EmrJobFlowSensor 2021-03-24T05:11:35.980916+00:00 2021-03-24T05:21:38.669002+00:00 0:10:02.688086 11139 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T05:11:33.667567+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-24T04:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T05:11:18.511135+00:00 2021-03-24T05:11:20.256701+00:00 0:00:01.745566 11138 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T05:11:15.584118+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-24T04:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T05:11:16.216612+00:00 2021-03-24T05:11:18.357447+00:00 0:00:02.140835 11137 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T05:11:13.663757+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-24T04:00:00+00:00 PythonOperator 2021-03-24T05:10:55.870489+00:00 2021-03-24T05:10:58.702529+00:00 0:00:02.832040 11136 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T05:10:53.538858+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-24T04:00:00+00:00 PythonOperator 2021-03-24T05:10:53.703497+00:00 2021-03-24T05:10:56.716143+00:00 0:00:03.012646 11135 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T05:10:51.535382+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-24T04:00:00+00:00 TriggerDagRunOperator 2021-03-24T05:10:35.839586+00:00 2021-03-24T05:10:36.332406+00:00 0:00:00.492820 11134 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T05:10:33.521738+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-24T04:00:00+00:00 TriggerDagRunOperator 2021-03-24T05:10:35.675779+00:00 2021-03-24T05:10:36.086939+00:00 0:00:00.411160 11133 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T05:10:33.521769+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-24T04:05:00+00:00 EmrJobFlowSensor 2021-03-24T05:05:51.153146+00:00 2021-03-24T05:14:53.819702+00:00 0:09:02.666556 11132 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T05:05:48.911120+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-24T04:05:00+00:00 EmrCreateJobFlowOperator 2021-03-24T05:05:29.252730+00:00 2021-03-24T05:05:30.967539+00:00 0:00:01.714809 11131 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T05:05:26.889666+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-24T04:05:00+00:00 PythonOperator 2021-03-24T05:05:08.990463+00:00 2021-03-24T05:05:11.692142+00:00 0:00:02.701679 11130 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T05:05:06.837771+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-24T04:00:00+00:00 EmrJobFlowSensor 2021-03-24T05:01:08.860539+00:00 2021-03-24T05:10:11.658983+00:00 0:09:02.798444 11129 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T05:01:06.537297+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-24T04:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T05:00:46.962428+00:00 2021-03-24T05:00:48.769401+00:00 0:00:01.806973 11128 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-24T05:00:44.573913+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-24T04:00:00+00:00 PythonOperator 2021-03-24T05:00:25.164357+00:00 2021-03-24T05:00:27.916003+00:00 0:00:02.751646 11127 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-24T05:00:22.572978+00:00 2 default_pool