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-05-09T12:05:00+00:00 EmrCreateJobFlowOperator 2021-05-09T13:05:30.709207+00:00 2021-05-09T13:05:32.490972+00:00 0:00:01.781765 26192 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-09T13:05:28.450662+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-09T12:05:00+00:00 PythonOperator 2021-05-09T13:05:08.542620+00:00 2021-05-09T13:05:11.684521+00:00 0:00:03.141901 26191 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T13:05:06.341062+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-09T12:00:00+00:00 EmrJobFlowSensor 2021-05-09T13:00:54.390255+00:00 2021-05-09T13:09:56.995509+00:00 0:09:02.605254 26190 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T13:00:52.050590+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-09T12:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T13:00:34.269745+00:00 2021-05-09T13:00:36.152263+00:00 0:00:01.882518 26189 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-09T13:00:31.925129+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-09T12:00:00+00:00 PythonOperator 2021-05-09T13:00:12.562018+00:00 2021-05-09T13:00:15.745269+00:00 0:00:03.183251 26188 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-09T13:00:09.904912+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-09T11:00:00+00:00 EmrJobFlowSensor 2021-05-09T12:11:32.418450+00:00 2021-05-09T12:20:34.920546+00:00 0:09:02.502096 26186 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T12:11:29.956402+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-09T11:00:00+00:00 EmrJobFlowSensor 2021-05-09T12:11:26.116443+00:00 2021-05-09T12:20:29.010122+00:00 0:09:02.893679 26185 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T12:11:23.809418+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-09T11:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T12:11:09.885247+00:00 2021-05-09T12:11:11.593101+00:00 0:00:01.707854 26184 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-09T12:11:07.757017+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-09T11:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T12:11:06.121166+00:00 2021-05-09T12:11:07.967184+00:00 0:00:01.846018 26183 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-09T12:11:03.759828+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-09T11:00:00+00:00 PythonOperator 2021-05-09T12:10:48.250548+00:00 2021-05-09T12:10:51.526241+00:00 0:00:03.275693 26182 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T12:10:45.762085+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-09T11:00:00+00:00 PythonOperator 2021-05-09T12:10:43.977183+00:00 2021-05-09T12:10:47.124619+00:00 0:00:03.147436 26181 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T12:10:41.748769+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-09T11:00:00+00:00 TriggerDagRunOperator 2021-05-09T12:10:14.251794+00:00 2021-05-09T12:10:14.791756+00:00 0:00:00.539962 26180 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T12:10:11.679983+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-09T11:00:00+00:00 TriggerDagRunOperator 2021-05-09T12:10:13.926435+00:00 2021-05-09T12:10:14.378142+00:00 0:00:00.451707 26179 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T12:10:11.679952+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-09T11:05:00+00:00 EmrJobFlowSensor 2021-05-09T12:06:05.464462+00:00 2021-05-09T12:15:08.145917+00:00 0:09:02.681455 26178 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T12:06:03.382438+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-09T11:05:00+00:00 EmrCreateJobFlowOperator 2021-05-09T12:05:43.404092+00:00 2021-05-09T12:05:45.007689+00:00 0:00:01.603597 26177 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-09T12:05:41.231629+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-09T11:05:00+00:00 PythonOperator 2021-05-09T12:05:23.372026+00:00 2021-05-09T12:05:26.423965+00:00 0:00:03.051939 26176 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T12:05:21.213462+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-09T11:00:00+00:00 EmrJobFlowSensor 2021-05-09T12:01:05.030532+00:00 2021-05-09T12:10:07.793102+00:00 0:09:02.762570 26175 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T12:01:02.684084+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-09T11:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T12:00:43.066492+00:00 2021-05-09T12:00:44.994980+00:00 0:00:01.928488 26174 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-09T12:00:40.669118+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-09T11:00:00+00:00 PythonOperator 2021-05-09T12:00:21.048312+00:00 2021-05-09T12:00:24.152582+00:00 0:00:03.104270 26173 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-09T12:00:18.608207+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-09T10:00:00+00:00 EmrJobFlowSensor 2021-05-09T11:10:25.947784+00:00 2021-05-09T11:20:28.708252+00:00 0:10:02.760468 26171 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T11:10:23.823878+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-09T10:00:00+00:00 EmrJobFlowSensor 2021-05-09T11:10:21.885923+00:00 2021-05-09T11:19:24.492309+00:00 0:09:02.606386 26170 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T11:10:19.818210+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-09T10:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T11:10:04.371010+00:00 2021-05-09T11:10:06.200496+00:00 0:00:01.829486 26169 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-09T11:10:01.861243+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-09T10:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T11:10:00.386909+00:00 2021-05-09T11:10:02.157996+00:00 0:00:01.771087 26168 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-09T11:09:57.865507+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-09T10:00:00+00:00 PythonOperator 2021-05-09T11:09:42.551525+00:00 2021-05-09T11:09:46.070061+00:00 0:00:03.518536 26167 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T11:09:39.764574+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-09T10:00:00+00:00 PythonOperator 2021-05-09T11:09:38.305054+00:00 2021-05-09T11:09:42.058489+00:00 0:00:03.753435 26166 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T11:09:35.762391+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-09T10:00:00+00:00 TriggerDagRunOperator 2021-05-09T11:09:18.333899+00:00 2021-05-09T11:09:18.840532+00:00 0:00:00.506633 26165 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T11:09:15.749271+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-09T10:00:00+00:00 TriggerDagRunOperator 2021-05-09T11:09:18.104109+00:00 2021-05-09T11:09:18.515278+00:00 0:00:00.411169 26164 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T11:09:15.749328+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-09T10:05:00+00:00 EmrJobFlowSensor 2021-05-09T11:05:59.794211+00:00 2021-05-09T11:15:02.760017+00:00 0:09:02.965806 26163 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T11:05:57.417472+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-09T10:05:00+00:00 EmrCreateJobFlowOperator 2021-05-09T11:05:37.455761+00:00 2021-05-09T11:05:39.112972+00:00 0:00:01.657211 26162 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-09T11:05:35.389444+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-09T10:05:00+00:00 PythonOperator 2021-05-09T11:05:17.551382+00:00 2021-05-09T11:05:20.598843+00:00 0:00:03.047461 26161 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T11:05:15.324524+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-09T10:00:00+00:00 EmrJobFlowSensor 2021-05-09T11:00:55.081251+00:00 2021-05-09T11:08:57.711607+00:00 0:08:02.630356 26160 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T11:00:52.801176+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-09T10:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T11:00:33.320923+00:00 2021-05-09T11:00:35.151808+00:00 0:00:01.830885 26159 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-09T11:00:30.851450+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-09T10:00:00+00:00 PythonOperator 2021-05-09T11:00:12.823660+00:00 2021-05-09T11:00:15.884933+00:00 0:00:03.061273 26158 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-09T11:00:10.584905+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-09T09:00:00+00:00 EmrJobFlowSensor 2021-05-09T10:11:23.199101+00:00 2021-05-09T10:21:25.958068+00:00 0:10:02.758967 26156 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T10:11:20.867027+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-09T09:00:00+00:00 EmrJobFlowSensor 2021-05-09T10:11:04.999047+00:00 2021-05-09T10:20:07.738731+00:00 0:09:02.739684 26155 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T10:11:02.791738+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-09T09:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T10:11:01.295742+00:00 2021-05-09T10:11:03.012184+00:00 0:00:01.716442 26154 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-09T10:10:58.863024+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-09T09:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T10:10:45.071793+00:00 2021-05-09T10:10:46.926244+00:00 0:00:01.854451 26153 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-09T10:10:42.711889+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-09T09:00:00+00:00 PythonOperator 2021-05-09T10:10:40.814112+00:00 2021-05-09T10:10:43.861106+00:00 0:00:03.046994 26152 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T10:10:38.705638+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-09T09:00:00+00:00 PythonOperator 2021-05-09T10:10:22.987678+00:00 2021-05-09T10:10:26.335138+00:00 0:00:03.347460 26151 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T10:10:20.692448+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-09T09:00:00+00:00 TriggerDagRunOperator 2021-05-09T10:10:17.037027+00:00 2021-05-09T10:10:17.600441+00:00 0:00:00.563414 26150 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T10:10:14.690065+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-09T09:00:00+00:00 TriggerDagRunOperator 2021-05-09T10:10:16.874836+00:00 2021-05-09T10:10:17.291533+00:00 0:00:00.416697 26149 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T10:10:14.690097+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-09T09:05:00+00:00 EmrJobFlowSensor 2021-05-09T10:06:06.350866+00:00 2021-05-09T10:15:08.990905+00:00 0:09:02.640039 26148 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T10:06:04.289415+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-09T09:05:00+00:00 EmrCreateJobFlowOperator 2021-05-09T10:05:36.487819+00:00 2021-05-09T10:05:38.236364+00:00 0:00:01.748545 26147 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-09T10:05:34.233820+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-09T09:05:00+00:00 PythonOperator 2021-05-09T10:05:06.447884+00:00 2021-05-09T10:05:09.488492+00:00 0:00:03.040608 26146 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T10:05:04.270807+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-09T09:00:00+00:00 EmrJobFlowSensor 2021-05-09T10:00:54.062801+00:00 2021-05-09T10:09:56.908691+00:00 0:09:02.845890 26145 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T10:00:51.814151+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-09T09:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T10:00:31.967138+00:00 2021-05-09T10:00:33.680852+00:00 0:00:01.713714 26144 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-09T10:00:29.793955+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-09T09:00:00+00:00 PythonOperator 2021-05-09T10:00:10.144396+00:00 2021-05-09T10:00:13.319368+00:00 0:00:03.174972 26143 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-09T10:00:07.756875+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-09T08:00:00+00:00 EmrJobFlowSensor 2021-05-09T09:11:27.489139+00:00 2021-05-09T09:19:30.053051+00:00 0:08:02.563912 26141 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T09:11:25.272184+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-09T08:00:00+00:00 EmrJobFlowSensor 2021-05-09T09:11:09.996468+00:00 2021-05-09T09:20:12.579433+00:00 0:09:02.582965 26140 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T09:11:07.264912+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-09T08:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T09:11:07.519699+00:00 2021-05-09T09:11:09.329442+00:00 0:00:01.809743 26139 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-09T09:11:05.243905+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-09T08:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T09:10:49.904115+00:00 2021-05-09T09:10:51.726496+00:00 0:00:01.822381 26138 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-09T09:10:47.142092+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-09T08:00:00+00:00 PythonOperator 2021-05-09T09:10:45.390412+00:00 2021-05-09T09:10:48.855339+00:00 0:00:03.464927 26137 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T09:10:43.134134+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-09T08:00:00+00:00 PythonOperator 2021-05-09T09:10:27.200378+00:00 2021-05-09T09:10:30.461290+00:00 0:00:03.260912 26136 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T09:10:25.119801+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-09T08:00:00+00:00 TriggerDagRunOperator 2021-05-09T09:10:23.449290+00:00 2021-05-09T09:10:23.977531+00:00 0:00:00.528241 26135 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T09:10:21.116775+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-09T08:00:00+00:00 TriggerDagRunOperator 2021-05-09T09:10:23.313181+00:00 2021-05-09T09:10:23.715137+00:00 0:00:00.401956 26134 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T09:10:21.116806+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-09T08:05:00+00:00 EmrJobFlowSensor 2021-05-09T09:06:06.706752+00:00 2021-05-09T09:14:09.381203+00:00 0:08:02.674451 26133 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T09:06:04.602084+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-09T08:05:00+00:00 EmrCreateJobFlowOperator 2021-05-09T09:05:44.988637+00:00 2021-05-09T09:05:46.772540+00:00 0:00:01.783903 26132 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-09T09:05:42.592115+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-09T08:05:00+00:00 PythonOperator 2021-05-09T09:05:24.798575+00:00 2021-05-09T09:05:27.880085+00:00 0:00:03.081510 26131 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T09:05:22.459600+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-09T08:00:00+00:00 EmrJobFlowSensor 2021-05-09T09:00:56.392259+00:00 2021-05-09T09:09:59.294094+00:00 0:09:02.901835 26130 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T09:00:54.151316+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-09T08:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T09:00:34.196862+00:00 2021-05-09T09:00:35.936645+00:00 0:00:01.739783 26129 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-09T09:00:32.042497+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-09T08:00:00+00:00 PythonOperator 2021-05-09T09:00:12.787072+00:00 2021-05-09T09:00:15.839224+00:00 0:00:03.052152 26128 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-09T09:00:10.052327+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-09T07:00:00+00:00 EmrJobFlowSensor 2021-05-09T08:11:47.343650+00:00 2021-05-09T08:20:49.965395+00:00 0:09:02.621745 26126 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T08:11:45.104269+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-09T07:00:00+00:00 EmrJobFlowSensor 2021-05-09T08:11:33.633183+00:00 2021-05-09T08:21:36.557727+00:00 0:10:02.924544 26125 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T08:11:31.160524+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-09T07:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T08:11:25.509586+00:00 2021-05-09T08:11:27.271349+00:00 0:00:01.761763 26124 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-09T08:11:23.143394+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-09T07:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T08:11:09.774725+00:00 2021-05-09T08:11:11.614701+00:00 0:00:01.839976 26123 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-09T08:11:06.989833+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-09T07:00:00+00:00 PythonOperator 2021-05-09T08:11:01.409544+00:00 2021-05-09T08:11:04.598601+00:00 0:00:03.189057 26122 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T08:10:59.052694+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-09T07:00:00+00:00 PythonOperator 2021-05-09T08:10:43.190767+00:00 2021-05-09T08:10:46.452346+00:00 0:00:03.261579 26121 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T08:10:40.919023+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-09T07:00:00+00:00 TriggerDagRunOperator 2021-05-09T08:10:33.533639+00:00 2021-05-09T08:10:34.065300+00:00 0:00:00.531661 26120 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T08:10:30.910465+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-09T07:00:00+00:00 TriggerDagRunOperator 2021-05-09T08:10:33.264706+00:00 2021-05-09T08:10:33.683621+00:00 0:00:00.418915 26119 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T08:10:30.910428+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-09T07:05:00+00:00 EmrJobFlowSensor 2021-05-09T08:05:46.443112+00:00 2021-05-09T08:14:48.946105+00:00 0:09:02.502993 26118 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T08:05:44.406441+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-09T07:05:00+00:00 EmrCreateJobFlowOperator 2021-05-09T08:05:24.657539+00:00 2021-05-09T08:05:26.355876+00:00 0:00:01.698337 26117 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-09T08:05:22.449685+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-09T07:05:00+00:00 PythonOperator 2021-05-09T08:05:04.733289+00:00 2021-05-09T08:05:07.772647+00:00 0:00:03.039358 26116 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T08:05:02.352248+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-09T07:00:00+00:00 EmrJobFlowSensor 2021-05-09T08:01:06.305022+00:00 2021-05-09T08:10:09.258914+00:00 0:09:02.953892 26115 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T08:01:03.866211+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-09T07:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T08:00:46.091937+00:00 2021-05-09T08:00:47.788594+00:00 0:00:01.696657 26114 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-09T08:00:43.805661+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-09T07:00:00+00:00 PythonOperator 2021-05-09T08:00:24.099260+00:00 2021-05-09T08:00:27.170871+00:00 0:00:03.071611 26113 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-09T08:00:21.789521+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-09T06:00:00+00:00 EmrJobFlowSensor 2021-05-09T07:11:28.620923+00:00 2021-05-09T07:19:31.111175+00:00 0:08:02.490252 26111 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T07:11:26.323143+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-09T06:00:00+00:00 EmrJobFlowSensor 2021-05-09T07:11:18.596694+00:00 2021-05-09T07:20:21.266556+00:00 0:09:02.669862 26110 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T07:11:16.376043+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-09T06:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T07:11:06.450926+00:00 2021-05-09T07:11:08.250272+00:00 0:00:01.799346 26109 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-09T07:11:04.288098+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-09T06:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T07:10:56.523329+00:00 2021-05-09T07:10:58.282778+00:00 0:00:01.759449 26108 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-09T07:10:54.244579+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-09T06:00:00+00:00 PythonOperator 2021-05-09T07:10:44.728309+00:00 2021-05-09T07:10:47.943154+00:00 0:00:03.214845 26107 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T07:10:42.230168+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-09T06:00:00+00:00 PythonOperator 2021-05-09T07:10:34.441664+00:00 2021-05-09T07:10:37.816307+00:00 0:00:03.374643 26106 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T07:10:32.248497+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-09T06:00:00+00:00 TriggerDagRunOperator 2021-05-09T07:10:24.920489+00:00 2021-05-09T07:10:25.441324+00:00 0:00:00.520835 26105 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T07:10:22.283047+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-09T06:00:00+00:00 TriggerDagRunOperator 2021-05-09T07:10:24.660357+00:00 2021-05-09T07:10:25.096084+00:00 0:00:00.435727 26104 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T07:10:22.283011+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-09T06:05:00+00:00 EmrJobFlowSensor 2021-05-09T07:06:00.521961+00:00 2021-05-09T07:15:03.171020+00:00 0:09:02.649059 26103 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T07:05:58.050002+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-09T06:05:00+00:00 EmrCreateJobFlowOperator 2021-05-09T07:05:40.296566+00:00 2021-05-09T07:05:42.010007+00:00 0:00:01.713441 26102 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-09T07:05:37.881792+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-09T06:05:00+00:00 PythonOperator 2021-05-09T07:05:17.911660+00:00 2021-05-09T07:05:20.933115+00:00 0:00:03.021455 26101 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T07:05:15.827642+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-09T06:00:00+00:00 EmrJobFlowSensor 2021-05-09T07:00:57.743369+00:00 2021-05-09T07:10:00.517716+00:00 0:09:02.774347 26100 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T07:00:55.454666+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-09T06:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T07:00:35.855755+00:00 2021-05-09T07:00:37.735721+00:00 0:00:01.879966 26099 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-09T07:00:33.455929+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-09T06:00:00+00:00 PythonOperator 2021-05-09T07:00:13.837588+00:00 2021-05-09T07:00:17.014482+00:00 0:00:03.176894 26098 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-09T07:00:11.379998+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-09T05:00:00+00:00 EmrJobFlowSensor 2021-05-09T06:23:28.809951+00:00 2021-05-09T06:33:31.707796+00:00 0:10:02.897845 26096 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T06:23:26.236686+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-09T05:00:00+00:00 EmrJobFlowSensor 2021-05-09T06:23:10.635185+00:00 2021-05-09T06:31:13.209751+00:00 0:08:02.574566 26095 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T06:23:08.263676+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-09T05:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T06:23:06.468091+00:00 2021-05-09T06:23:08.156869+00:00 0:00:01.688778 26094 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-09T06:23:04.273833+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-09T05:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T06:22:48.480295+00:00 2021-05-09T06:22:50.275655+00:00 0:00:01.795360 26093 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-09T06:22:46.153678+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-09T05:00:00+00:00 PythonOperator 2021-05-09T06:22:46.383981+00:00 2021-05-09T06:22:49.651356+00:00 0:00:03.267375 26092 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T06:22:44.186773+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-09T05:00:00+00:00 PythonOperator 2021-05-09T06:22:28.340627+00:00 2021-05-09T06:22:31.478732+00:00 0:00:03.138105 26091 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T06:22:26.132466+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-09T05:00:00+00:00 TriggerDagRunOperator 2021-05-09T06:22:22.465000+00:00 2021-05-09T06:22:22.985810+00:00 0:00:00.520810 26090 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T06:22:20.127610+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-09T05:00:00+00:00 TriggerDagRunOperator 2021-05-09T06:22:22.305466+00:00 2021-05-09T06:22:22.741228+00:00 0:00:00.435762 26089 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T06:22:20.127580+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-09T05:05:00+00:00 EmrJobFlowSensor 2021-05-09T06:05:56.965469+00:00 2021-05-09T06:13:59.458919+00:00 0:08:02.493450 26088 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T06:05:54.762974+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-09T05:05:00+00:00 EmrCreateJobFlowOperator 2021-05-09T06:05:34.979837+00:00 2021-05-09T06:05:36.750608+00:00 0:00:01.770771 26087 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-09T06:05:32.682060+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-09T05:05:00+00:00 PythonOperator 2021-05-09T06:05:15.104055+00:00 2021-05-09T06:05:18.226958+00:00 0:00:03.122903 26086 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T06:05:12.657480+00:00 2 default_pool