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_emr_steps 2021-05-23T07:05:00+00:00 PythonOperator 2021-05-23T08:05:13.449926+00:00 2021-05-23T08:05:16.598828+00:00 0:00:03.148902 31202 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-23T08:05:11.343136+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-23T07:00:00+00:00 EmrJobFlowSensor 2021-05-23T08:01:01.320104+00:00 2021-05-23T08:11:04.179307+00:00 0:10:02.859203 31201 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-23T08:00:58.981517+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-23T07:00:00+00:00 EmrCreateJobFlowOperator 2021-05-23T08:00:41.121642+00:00 2021-05-23T08:00:42.912963+00:00 0:00:01.791321 31200 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-23T08:00:38.889215+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-23T07:00:00+00:00 PythonOperator 2021-05-23T08:00:19.193117+00:00 2021-05-23T08:00:22.411205+00:00 0:00:03.218088 31199 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-23T08:00:16.747690+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-23T06:00:00+00:00 EmrJobFlowSensor 2021-05-23T07:12:26.110603+00:00 2021-05-23T07:21:28.912706+00:00 0:09:02.802103 31197 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-23T07:12:23.605225+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-23T06:00:00+00:00 EmrJobFlowSensor 2021-05-23T07:12:25.777078+00:00 2021-05-23T07:20:28.313143+00:00 0:08:02.536065 31196 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-23T07:12:23.605252+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-23T06:00:00+00:00 EmrCreateJobFlowOperator 2021-05-23T07:12:06.117442+00:00 2021-05-23T07:12:07.802446+00:00 0:00:01.685004 31195 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-23T07:12:03.596331+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-23T06:00:00+00:00 EmrCreateJobFlowOperator 2021-05-23T07:12:03.766508+00:00 2021-05-23T07:12:05.827491+00:00 0:00:02.060983 31194 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-23T07:12:01.589477+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-23T06:00:00+00:00 PythonOperator 2021-05-23T07:11:44.566708+00:00 2021-05-23T07:11:47.804619+00:00 0:00:03.237911 31193 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-23T07:11:41.561047+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-23T06:00:00+00:00 PythonOperator 2021-05-23T07:11:42.430716+00:00 2021-05-23T07:11:46.267608+00:00 0:00:03.836892 31192 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-23T07:11:39.561306+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-23T06:00:00+00:00 TriggerDagRunOperator 2021-05-23T07:11:34.338570+00:00 2021-05-23T07:11:34.862377+00:00 0:00:00.523807 31191 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-23T07:11:31.584094+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-23T06:00:00+00:00 TriggerDagRunOperator 2021-05-23T07:11:34.103858+00:00 2021-05-23T07:11:34.501925+00:00 0:00:00.398067 31190 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-23T07:11:31.584048+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-23T06:05:00+00:00 EmrJobFlowSensor 2021-05-23T07:05:56.985413+00:00 2021-05-23T07:14:59.619277+00:00 0:09:02.633864 31189 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-23T07:05:54.902878+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-23T06:05:00+00:00 EmrCreateJobFlowOperator 2021-05-23T07:05:35.426683+00:00 2021-05-23T07:05:37.135471+00:00 0:00:01.708788 31188 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-23T07:05:32.955264+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-23T06:05:00+00:00 PythonOperator 2021-05-23T07:05:13.092025+00:00 2021-05-23T07:05:16.256902+00:00 0:00:03.164877 31187 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-23T07:05:10.940791+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-23T06:00:00+00:00 EmrJobFlowSensor 2021-05-23T07:01:07.086707+00:00 2021-05-23T07:11:09.832256+00:00 0:10:02.745549 31186 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-23T07:01:04.376368+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-23T06:00:00+00:00 EmrCreateJobFlowOperator 2021-05-23T07:00:46.573881+00:00 2021-05-23T07:00:48.371595+00:00 0:00:01.797714 31185 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-23T07:00:44.292433+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-23T06:00:00+00:00 PythonOperator 2021-05-23T07:00:24.585173+00:00 2021-05-23T07:00:27.800335+00:00 0:00:03.215162 31184 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-23T07:00:22.249624+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-23T05:00:00+00:00 EmrJobFlowSensor 2021-05-23T06:11:16.595102+00:00 2021-05-23T06:21:19.259079+00:00 0:10:02.663977 31182 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-23T06:11:14.359638+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-23T05:00:00+00:00 EmrJobFlowSensor 2021-05-23T06:11:12.668934+00:00 2021-05-23T06:20:15.320475+00:00 0:09:02.651541 31181 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-23T06:11:10.346431+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-23T05:00:00+00:00 EmrCreateJobFlowOperator 2021-05-23T06:10:46.419921+00:00 2021-05-23T06:10:48.153942+00:00 0:00:01.734021 31180 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-23T06:10:44.233528+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-23T05:00:00+00:00 EmrCreateJobFlowOperator 2021-05-23T06:10:40.437846+00:00 2021-05-23T06:10:42.210739+00:00 0:00:01.772893 31179 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-23T06:10:38.245746+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-23T05:00:00+00:00 PythonOperator 2021-05-23T06:10:20.372052+00:00 2021-05-23T06:10:23.784094+00:00 0:00:03.412042 31178 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-23T06:10:18.204109+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-23T05:00:00+00:00 PythonOperator 2021-05-23T06:10:14.831057+00:00 2021-05-23T06:10:17.959477+00:00 0:00:03.128420 31177 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-23T06:10:12.266776+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-23T05:00:00+00:00 TriggerDagRunOperator 2021-05-23T06:10:02.866552+00:00 2021-05-23T06:10:03.400092+00:00 0:00:00.533540 31176 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-23T06:10:00.186275+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-23T05:00:00+00:00 TriggerDagRunOperator 2021-05-23T06:10:02.463134+00:00 2021-05-23T06:10:03.034564+00:00 0:00:00.571430 31175 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-23T06:10:00.186308+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-23T05:05:00+00:00 EmrJobFlowSensor 2021-05-23T06:05:50.062047+00:00 2021-05-23T06:14:52.576021+00:00 0:09:02.513974 31174 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-23T06:05:47.862879+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-23T05:05:00+00:00 EmrCreateJobFlowOperator 2021-05-23T06:05:30.319890+00:00 2021-05-23T06:05:31.943575+00:00 0:00:01.623685 31173 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-23T06:05:27.851555+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-23T05:05:00+00:00 PythonOperator 2021-05-23T06:05:07.757347+00:00 2021-05-23T06:05:10.934162+00:00 0:00:03.176815 31172 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-23T06:05:05.638465+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-23T05:00:00+00:00 EmrJobFlowSensor 2021-05-23T06:00:51.576786+00:00 2021-05-23T06:09:54.280865+00:00 0:09:02.704079 31171 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-23T06:00:49.323415+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-23T05:00:00+00:00 EmrCreateJobFlowOperator 2021-05-23T06:00:27.680951+00:00 2021-05-23T06:00:29.344946+00:00 0:00:01.663995 31170 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-23T06:00:25.362321+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-23T05:00:00+00:00 PythonOperator 2021-05-23T06:00:05.947160+00:00 2021-05-23T06:00:09.269412+00:00 0:00:03.322252 31169 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-23T06:00:03.288323+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-23T04:00:00+00:00 EmrJobFlowSensor 2021-05-23T05:11:29.253191+00:00 2021-05-23T05:21:31.955888+00:00 0:10:02.702697 31167 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-23T05:11:26.807754+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-23T04:00:00+00:00 EmrJobFlowSensor 2021-05-23T05:11:26.880209+00:00 2021-05-23T05:19:29.567463+00:00 0:08:02.687254 31166 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-23T05:11:24.796181+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-23T04:00:00+00:00 EmrCreateJobFlowOperator 2021-05-23T05:11:06.991642+00:00 2021-05-23T05:11:08.803054+00:00 0:00:01.811412 31165 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-23T05:11:04.790042+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-23T04:00:00+00:00 EmrCreateJobFlowOperator 2021-05-23T05:11:05.300021+00:00 2021-05-23T05:11:07.163376+00:00 0:00:01.863355 31164 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-23T05:11:02.788233+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-23T04:00:00+00:00 PythonOperator 2021-05-23T05:10:45.318368+00:00 2021-05-23T05:10:48.828567+00:00 0:00:03.510199 31163 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-23T05:10:42.692037+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-23T04:00:00+00:00 PythonOperator 2021-05-23T05:10:42.874431+00:00 2021-05-23T05:10:46.384587+00:00 0:00:03.510156 31162 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-23T05:10:40.685278+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-23T04:00:00+00:00 TriggerDagRunOperator 2021-05-23T05:10:25.056575+00:00 2021-05-23T05:10:25.572019+00:00 0:00:00.515444 31161 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-23T05:10:22.632230+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-23T04:00:00+00:00 TriggerDagRunOperator 2021-05-23T05:10:24.932623+00:00 2021-05-23T05:10:25.373338+00:00 0:00:00.440715 31160 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-23T05:10:22.632267+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-23T04:05:00+00:00 EmrJobFlowSensor 2021-05-23T05:05:48.434697+00:00 2021-05-23T05:14:51.031904+00:00 0:09:02.597207 31159 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-23T05:05:46.224396+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-23T04:05:00+00:00 EmrCreateJobFlowOperator 2021-05-23T05:05:28.351283+00:00 2021-05-23T05:05:29.981516+00:00 0:00:01.630233 31158 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-23T05:05:26.133939+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-23T04:05:00+00:00 PythonOperator 2021-05-23T05:05:06.391142+00:00 2021-05-23T05:05:09.434096+00:00 0:00:03.042954 31157 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-23T05:05:04.154295+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-23T04:00:00+00:00 EmrJobFlowSensor 2021-05-23T05:01:10.167242+00:00 2021-05-23T05:10:12.825652+00:00 0:09:02.658410 31156 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-23T05:01:07.833024+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-23T04:00:00+00:00 EmrCreateJobFlowOperator 2021-05-23T05:00:42.006862+00:00 2021-05-23T05:00:43.823869+00:00 0:00:01.817007 31155 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-23T05:00:39.809382+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-23T04:00:00+00:00 PythonOperator 2021-05-23T05:00:20.362915+00:00 2021-05-23T05:00:23.467029+00:00 0:00:03.104114 31154 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-23T05:00:17.792264+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-23T03:00:00+00:00 EmrJobFlowSensor 2021-05-23T04:11:13.694323+00:00 2021-05-23T04:20:16.272636+00:00 0:09:02.578313 31152 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-23T04:11:11.527478+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-23T03:00:00+00:00 EmrJobFlowSensor 2021-05-23T04:11:11.724531+00:00 2021-05-23T04:20:14.623008+00:00 0:09:02.898477 31151 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-23T04:11:09.528870+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-23T03:00:00+00:00 EmrCreateJobFlowOperator 2021-05-23T04:10:51.964414+00:00 2021-05-23T04:10:53.662053+00:00 0:00:01.697639 31150 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-23T04:10:49.509100+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-23T03:00:00+00:00 EmrCreateJobFlowOperator 2021-05-23T04:10:49.729896+00:00 2021-05-23T04:10:51.692860+00:00 0:00:01.962964 31149 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-23T04:10:47.516548+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-23T03:00:00+00:00 PythonOperator 2021-05-23T04:10:30.099384+00:00 2021-05-23T04:10:33.229275+00:00 0:00:03.129891 31148 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-23T04:10:27.551212+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-23T03:00:00+00:00 PythonOperator 2021-05-23T04:10:27.723859+00:00 2021-05-23T04:10:31.226738+00:00 0:00:03.502879 31147 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-23T04:10:25.546446+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-23T03:00:00+00:00 TriggerDagRunOperator 2021-05-23T04:10:12.027291+00:00 2021-05-23T04:10:12.549337+00:00 0:00:00.522046 31146 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-23T04:10:09.557890+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-23T03:00:00+00:00 TriggerDagRunOperator 2021-05-23T04:10:11.861864+00:00 2021-05-23T04:10:12.281778+00:00 0:00:00.419914 31145 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-23T04:10:09.557851+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-23T03:05:00+00:00 EmrJobFlowSensor 2021-05-23T04:05:53.194512+00:00 2021-05-23T04:14:55.645193+00:00 0:09:02.450681 31144 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-23T04:05:50.981819+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-23T03:05:00+00:00 EmrCreateJobFlowOperator 2021-05-23T04:05:31.397761+00:00 2021-05-23T04:05:33.022079+00:00 0:00:01.624318 31143 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-23T04:05:29.066845+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-23T03:05:00+00:00 PythonOperator 2021-05-23T04:05:10.968606+00:00 2021-05-23T04:05:14.229017+00:00 0:00:03.260411 31142 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-23T04:05:08.896126+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-23T03:00:00+00:00 EmrJobFlowSensor 2021-05-23T04:00:56.703990+00:00 2021-05-23T04:09:59.308655+00:00 0:09:02.604665 31141 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-23T04:00:54.575505+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-23T03:00:00+00:00 EmrCreateJobFlowOperator 2021-05-23T04:00:36.687849+00:00 2021-05-23T04:00:38.388000+00:00 0:00:01.700151 31140 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-23T04:00:34.557701+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-23T03:00:00+00:00 PythonOperator 2021-05-23T04:00:12.994593+00:00 2021-05-23T04:00:16.219236+00:00 0:00:03.224643 31139 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-23T04:00:10.544280+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-23T02:00:00+00:00 EmrJobFlowSensor 2021-05-23T03:11:28.490166+00:00 2021-05-23T03:20:31.128648+00:00 0:09:02.638482 31137 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-23T03:11:25.814812+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-23T02:00:00+00:00 EmrJobFlowSensor 2021-05-23T03:11:26.294233+00:00 2021-05-23T03:21:29.414997+00:00 0:10:03.120764 31136 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-23T03:11:23.813715+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-23T02:00:00+00:00 EmrCreateJobFlowOperator 2021-05-23T03:11:06.344660+00:00 2021-05-23T03:11:08.032323+00:00 0:00:01.687663 31135 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-23T03:11:03.795386+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-23T02:00:00+00:00 EmrCreateJobFlowOperator 2021-05-23T03:11:04.101488+00:00 2021-05-23T03:11:06.123874+00:00 0:00:02.022386 31134 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-23T03:11:01.804932+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-23T02:00:00+00:00 PythonOperator 2021-05-23T03:10:43.892910+00:00 2021-05-23T03:10:47.065195+00:00 0:00:03.172285 31133 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-23T03:10:41.753335+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-23T02:00:00+00:00 PythonOperator 2021-05-23T03:10:42.020321+00:00 2021-05-23T03:10:45.599765+00:00 0:00:03.579444 31132 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-23T03:10:39.749242+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-23T02:00:00+00:00 TriggerDagRunOperator 2021-05-23T03:10:28.039760+00:00 2021-05-23T03:10:28.563054+00:00 0:00:00.523294 31131 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-23T03:10:25.671452+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-23T02:00:00+00:00 TriggerDagRunOperator 2021-05-23T03:10:27.827661+00:00 2021-05-23T03:10:28.240181+00:00 0:00:00.412520 31130 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-23T03:10:25.671484+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-23T02:05:00+00:00 EmrJobFlowSensor 2021-05-23T03:05:51.457320+00:00 2021-05-23T03:14:54.005539+00:00 0:09:02.548219 31129 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-23T03:05:49.356074+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-23T02:05:00+00:00 EmrCreateJobFlowOperator 2021-05-23T03:05:29.868908+00:00 2021-05-23T03:05:31.619685+00:00 0:00:01.750777 31128 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-23T03:05:27.285878+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-23T02:05:00+00:00 PythonOperator 2021-05-23T03:05:07.467222+00:00 2021-05-23T03:05:10.627224+00:00 0:00:03.160002 31127 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-23T03:05:05.253061+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-23T02:00:00+00:00 EmrJobFlowSensor 2021-05-23T03:01:06.772757+00:00 2021-05-23T03:10:09.466589+00:00 0:09:02.693832 31126 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-23T03:01:04.625666+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-23T02:00:00+00:00 EmrCreateJobFlowOperator 2021-05-23T03:00:37.133021+00:00 2021-05-23T03:00:38.975510+00:00 0:00:01.842489 31125 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-23T03:00:34.655947+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-23T02:00:00+00:00 PythonOperator 2021-05-23T03:00:14.848313+00:00 2021-05-23T03:00:18.033737+00:00 0:00:03.185424 31124 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-23T03:00:12.601741+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-23T01:00:00+00:00 EmrJobFlowSensor 2021-05-23T02:19:36.634843+00:00 2021-05-23T02:28:39.414988+00:00 0:09:02.780145 31123 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-23T02:19:34.389871+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-23T01:00:00+00:00 EmrCreateJobFlowOperator 2021-05-23T02:19:14.644675+00:00 2021-05-23T02:19:16.326483+00:00 0:00:01.681808 31122 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-23T02:19:12.375015+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-23T01:00:00+00:00 EmrJobFlowSensor 2021-05-23T02:19:13.055421+00:00 2021-05-23T02:20:14.725502+00:00 0:01:01.670081 31121 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-23T02:19:10.371497+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-23T01:00:00+00:00 EmrCreateJobFlowOperator 2021-05-23T02:10:41.002948+00:00 2021-05-23T02:10:42.703406+00:00 0:00:01.700458 31119 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-23T02:10:38.890932+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-23T01:00:00+00:00 PythonOperator 2021-05-23T02:10:37.148919+00:00 2021-05-23T02:10:40.284515+00:00 0:00:03.135596 31118 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-23T02:10:34.885868+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-23T01:00:00+00:00 PythonOperator 2021-05-23T02:10:17.035117+00:00 2021-05-23T02:10:20.454651+00:00 0:00:03.419534 31117 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-23T02:10:14.847802+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-23T01:00:00+00:00 TriggerDagRunOperator 2021-05-23T02:10:11.134984+00:00 2021-05-23T02:10:11.667808+00:00 0:00:00.532824 31116 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-23T02:10:08.842558+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-23T01:00:00+00:00 TriggerDagRunOperator 2021-05-23T02:10:11.001737+00:00 2021-05-23T02:10:11.461277+00:00 0:00:00.459540 31115 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-23T02:10:08.842595+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-23T01:05:00+00:00 EmrJobFlowSensor 2021-05-23T02:05:50.741669+00:00 2021-05-23T02:14:53.348362+00:00 0:09:02.606693 31114 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-23T02:05:48.421064+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-23T01:05:00+00:00 EmrCreateJobFlowOperator 2021-05-23T02:05:28.570280+00:00 2021-05-23T02:05:30.252380+00:00 0:00:01.682100 31113 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-23T02:05:26.398951+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-23T01:05:00+00:00 PythonOperator 2021-05-23T02:05:06.547814+00:00 2021-05-23T02:05:09.605621+00:00 0:00:03.057807 31112 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-23T02:05:04.329728+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-23T01:00:00+00:00 EmrJobFlowSensor 2021-05-23T02:00:54.369745+00:00 2021-05-23T02:09:57.003332+00:00 0:09:02.633587 31111 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-23T02:00:51.967205+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-23T01:00:00+00:00 EmrCreateJobFlowOperator 2021-05-23T02:00:32.484110+00:00 2021-05-23T02:00:34.178699+00:00 0:00:01.694589 31110 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-23T02:00:30.046916+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-23T01:00:00+00:00 PythonOperator 2021-05-23T02:00:12.134713+00:00 2021-05-23T02:00:15.334744+00:00 0:00:03.200031 31109 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-23T02:00:09.817942+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-23T00:00:00+00:00 EmrJobFlowSensor 2021-05-23T01:12:07.593283+00:00 2021-05-23T01:21:10.356656+00:00 0:09:02.763373 31108 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-23T01:12:05.205232+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-23T00:00:00+00:00 EmrJobFlowSensor 2021-05-23T01:12:01.405635+00:00 2021-05-23T01:20:03.765592+00:00 0:08:02.359957 31107 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-23T01:11:59.204982+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-23T00:00:00+00:00 EmrCreateJobFlowOperator 2021-05-23T01:11:43.402361+00:00 2021-05-23T01:11:45.111584+00:00 0:00:01.709223 31106 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-23T01:11:41.170158+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-23T00:00:00+00:00 EmrCreateJobFlowOperator 2021-05-23T01:11:39.414363+00:00 2021-05-23T01:11:41.111389+00:00 0:00:01.697026 31105 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-23T01:11:37.143905+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-23T00:00:00+00:00 PythonOperator 2021-05-23T01:11:24.170083+00:00 2021-05-23T01:11:27.675164+00:00 0:00:03.505081 31104 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-23T01:11:21.110101+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-23T00:00:00+00:00 PythonOperator 2021-05-23T01:11:19.367642+00:00 2021-05-23T01:11:23.693548+00:00 0:00:04.325906 31103 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-23T01:11:17.105507+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-23T00:00:00+00:00 TriggerDagRunOperator 2021-05-23T01:11:03.648775+00:00 2021-05-23T01:11:04.195542+00:00 0:00:00.546767 31102 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-23T01:11:01.094198+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-23T00:00:00+00:00 TriggerDagRunOperator 2021-05-23T01:11:03.551224+00:00 2021-05-23T01:11:03.941848+00:00 0:00:00.390624 31101 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-23T01:11:01.094168+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-23T00:05:00+00:00 EmrJobFlowSensor 2021-05-23T01:06:07.828088+00:00 2021-05-23T01:14:10.377155+00:00 0:08:02.549067 31099 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-23T01:06:05.534223+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-23T00:05:00+00:00 EmrCreateJobFlowOperator 2021-05-23T01:05:46.049290+00:00 2021-05-23T01:05:47.685867+00:00 0:00:01.636577 31098 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-23T01:05:43.579556+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-23T00:05:00+00:00 PythonOperator 2021-05-23T01:05:15.687138+00:00 2021-05-23T01:05:18.855782+00:00 0:00:03.168644 31097 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-23T01:05:13.481952+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-23T00:00:00+00:00 EmrJobFlowSensor 2021-05-23T01:00:55.501919+00:00 2021-05-23T01:09:58.203721+00:00 0:09:02.701802 31096 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-23T01:00:53.073829+00:00 2 default_pool