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 campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-20T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-20T12:00:38.014774+00:00 2021-04-20T12:00:39.734795+00:00 0:00:01.720021 19256 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-20T12:00:35.785343+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-20T11:00:00+00:00 PythonOperator 2021-04-20T12:00:11.877219+00:00 2021-04-20T12:00:14.874865+00:00 0:00:02.997646 19255 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-20T12:00:09.637773+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-20T10:00:00+00:00 EmrJobFlowSensor 2021-04-20T11:11:47.340449+00:00 2021-04-20T11:20:49.969609+00:00 0:09:02.629160 19254 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T11:11:44.766713+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-20T10:00:00+00:00 EmrJobFlowSensor 2021-04-20T11:11:43.455754+00:00 2021-04-20T11:21:46.209561+00:00 0:10:02.753807 19253 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T11:11:40.766856+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-20T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-20T11:11:25.055162+00:00 2021-04-20T11:11:26.737868+00:00 0:00:01.682706 19252 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-20T11:11:22.752157+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-20T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-20T11:11:21.018820+00:00 2021-04-20T11:11:22.710587+00:00 0:00:01.691767 19251 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-20T11:11:18.747848+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-20T10:00:00+00:00 PythonOperator 2021-04-20T11:11:04.916644+00:00 2021-04-20T11:11:07.920604+00:00 0:00:03.003960 19250 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-20T11:11:02.687372+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-20T10:00:00+00:00 PythonOperator 2021-04-20T11:10:58.933801+00:00 2021-04-20T11:11:02.098462+00:00 0:00:03.164661 19249 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-20T11:10:56.660838+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-20T10:00:00+00:00 TriggerDagRunOperator 2021-04-20T11:10:45.304884+00:00 2021-04-20T11:10:45.821588+00:00 0:00:00.516704 19248 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T11:10:42.654560+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-20T10:00:00+00:00 TriggerDagRunOperator 2021-04-20T11:10:44.990034+00:00 2021-04-20T11:10:45.489325+00:00 0:00:00.499291 19247 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T11:10:42.654588+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-20T10:05:00+00:00 EmrJobFlowSensor 2021-04-20T11:05:58.165980+00:00 2021-04-20T11:15:00.794068+00:00 0:09:02.628088 19245 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T11:05:56.007291+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-20T10:05:00+00:00 EmrCreateJobFlowOperator 2021-04-20T11:05:36.143930+00:00 2021-04-20T11:05:37.775667+00:00 0:00:01.631737 19244 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-20T11:05:33.991196+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-20T10:05:00+00:00 PythonOperator 2021-04-20T11:05:16.118141+00:00 2021-04-20T11:05:19.068436+00:00 0:00:02.950295 19243 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-20T11:05:13.926185+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-20T10:00:00+00:00 EmrJobFlowSensor 2021-04-20T11:00:50.016849+00:00 2021-04-20T11:09:52.810638+00:00 0:09:02.793789 19242 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-20T11:00:47.664538+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-20T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-20T11:00:28.329769+00:00 2021-04-20T11:00:30.072801+00:00 0:00:01.743032 19241 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-20T11:00:25.673723+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-20T10:00:00+00:00 PythonOperator 2021-04-20T11:00:05.910875+00:00 2021-04-20T11:00:08.949720+00:00 0:00:03.038845 19240 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-20T11:00:03.605533+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-20T09:00:00+00:00 EmrJobFlowSensor 2021-04-20T10:11:46.561628+00:00 2021-04-20T10:21:49.338283+00:00 0:10:02.776655 19239 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T10:11:44.396332+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-20T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-20T10:11:24.500917+00:00 2021-04-20T10:11:26.279260+00:00 0:00:01.778343 19238 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-20T10:11:22.308728+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-20T09:00:00+00:00 EmrJobFlowSensor 2021-04-20T10:11:11.518841+00:00 2021-04-20T10:21:14.327007+00:00 0:10:02.808166 19237 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T10:11:08.343583+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-20T09:00:00+00:00 PythonOperator 2021-04-20T10:11:02.974479+00:00 2021-04-20T10:11:05.892739+00:00 0:00:02.918260 19236 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-20T10:11:00.362240+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-20T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-20T10:10:48.797668+00:00 2021-04-20T10:10:50.630632+00:00 0:00:01.832964 19235 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-20T10:10:46.351504+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-20T09:00:00+00:00 PythonOperator 2021-04-20T10:10:26.573915+00:00 2021-04-20T10:10:29.761936+00:00 0:00:03.188021 19234 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-20T10:10:24.255544+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-20T09:00:00+00:00 TriggerDagRunOperator 2021-04-20T10:10:09.118398+00:00 2021-04-20T10:10:09.618985+00:00 0:00:00.500587 19233 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T10:10:06.236631+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-20T09:00:00+00:00 TriggerDagRunOperator 2021-04-20T10:10:08.541496+00:00 2021-04-20T10:10:09.184870+00:00 0:00:00.643374 19232 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T10:10:06.236661+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-20T09:05:00+00:00 EmrJobFlowSensor 2021-04-20T10:09:08.291159+00:00 2021-04-20T10:17:10.867934+00:00 0:08:02.576775 19231 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T10:09:06.182262+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-20T09:05:00+00:00 EmrCreateJobFlowOperator 2021-04-20T10:08:48.332237+00:00 2021-04-20T10:08:50.272487+00:00 0:00:01.940250 19230 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-20T10:08:46.123270+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-20T09:05:00+00:00 PythonOperator 2021-04-20T10:08:26.987791+00:00 2021-04-20T10:08:29.917659+00:00 0:00:02.929868 19229 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-20T10:08:24.105867+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-20T09:00:00+00:00 EmrJobFlowSensor 2021-04-20T10:00:58.601467+00:00 2021-04-20T10:10:01.352218+00:00 0:09:02.750751 19227 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-20T10:00:56.265858+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-20T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-20T10:00:39.016786+00:00 2021-04-20T10:00:40.742414+00:00 0:00:01.725628 19226 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-20T10:00:36.255954+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-20T09:00:00+00:00 PythonOperator 2021-04-20T10:00:16.317462+00:00 2021-04-20T10:00:19.678296+00:00 0:00:03.360834 19225 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-20T10:00:14.121750+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-20T08:00:00+00:00 EmrJobFlowSensor 2021-04-20T09:16:50.517815+00:00 2021-04-20T09:25:53.052983+00:00 0:09:02.535168 19224 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T09:16:47.407477+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-20T08:00:00+00:00 EmrJobFlowSensor 2021-04-20T09:16:45.994035+00:00 2021-04-20T09:25:48.737329+00:00 0:09:02.743294 19223 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T09:16:43.459578+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-20T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-20T09:16:28.222448+00:00 2021-04-20T09:16:29.943730+00:00 0:00:01.721282 19222 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-20T09:16:25.394319+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-20T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-20T09:16:25.739043+00:00 2021-04-20T09:16:27.913892+00:00 0:00:02.174849 19221 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-20T09:16:23.451427+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-20T08:00:00+00:00 PythonOperator 2021-04-20T09:16:07.449151+00:00 2021-04-20T09:16:10.335575+00:00 0:00:02.886424 19220 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-20T09:16:05.312340+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-20T08:00:00+00:00 PythonOperator 2021-04-20T09:16:03.823357+00:00 2021-04-20T09:16:07.062964+00:00 0:00:03.239607 19219 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-20T09:16:01.376450+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-20T08:00:00+00:00 TriggerDagRunOperator 2021-04-20T09:15:51.503409+00:00 2021-04-20T09:15:52.044884+00:00 0:00:00.541475 19218 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T09:15:49.297484+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-20T08:00:00+00:00 TriggerDagRunOperator 2021-04-20T09:15:51.453448+00:00 2021-04-20T09:15:51.861874+00:00 0:00:00.408426 19217 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T09:15:49.297452+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-20T08:05:00+00:00 EmrJobFlowSensor 2021-04-20T09:06:02.599128+00:00 2021-04-20T09:15:05.271617+00:00 0:09:02.672489 19216 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T09:06:00.252882+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-20T08:05:00+00:00 EmrCreateJobFlowOperator 2021-04-20T09:05:40.257663+00:00 2021-04-20T09:05:41.905303+00:00 0:00:01.647640 19215 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-20T09:05:38.111112+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-20T08:00:00+00:00 EmrJobFlowSensor 2021-04-20T09:05:38.427932+00:00 2021-04-20T09:15:41.322384+00:00 0:10:02.894452 19214 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-20T09:05:36.088400+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-20T08:05:00+00:00 PythonOperator 2021-04-20T09:05:20.318904+00:00 2021-04-20T09:05:23.277050+00:00 0:00:02.958146 19213 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-20T09:05:18.045520+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-20T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-20T09:05:18.324525+00:00 2021-04-20T09:05:20.133303+00:00 0:00:01.808778 19212 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-20T09:05:16.043424+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-20T08:00:00+00:00 PythonOperator 2021-04-20T09:04:56.802401+00:00 2021-04-20T09:04:59.712232+00:00 0:00:02.909831 19211 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-20T09:04:53.834814+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-20T07:00:00+00:00 EmrJobFlowSensor 2021-04-20T08:11:33.708873+00:00 2021-04-20T08:20:36.427893+00:00 0:09:02.719020 19209 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T08:11:31.390259+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-20T07:00:00+00:00 EmrJobFlowSensor 2021-04-20T08:11:20.154390+00:00 2021-04-20T08:20:22.751707+00:00 0:09:02.597317 19208 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T08:11:17.362661+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-20T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-20T08:11:11.612455+00:00 2021-04-20T08:11:13.338682+00:00 0:00:01.726227 19207 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-20T08:11:09.381203+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-20T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-20T08:10:59.712560+00:00 2021-04-20T08:11:01.613249+00:00 0:00:01.900689 19206 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-20T08:10:57.325666+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-20T07:00:00+00:00 PythonOperator 2021-04-20T08:10:51.512486+00:00 2021-04-20T08:10:54.631596+00:00 0:00:03.119110 19205 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-20T08:10:49.318593+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-20T07:00:00+00:00 PythonOperator 2021-04-20T08:10:37.954827+00:00 2021-04-20T08:10:40.849222+00:00 0:00:02.894395 19204 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-20T08:10:35.307166+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-20T07:00:00+00:00 TriggerDagRunOperator 2021-04-20T08:10:29.742699+00:00 2021-04-20T08:10:30.210857+00:00 0:00:00.468158 19203 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T08:10:27.302873+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-20T07:00:00+00:00 TriggerDagRunOperator 2021-04-20T08:10:29.738503+00:00 2021-04-20T08:10:30.314389+00:00 0:00:00.575886 19202 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T08:10:27.302905+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-20T07:05:00+00:00 EmrJobFlowSensor 2021-04-20T08:06:06.872312+00:00 2021-04-20T08:15:09.562402+00:00 0:09:02.690090 19201 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T08:06:04.740023+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-20T07:05:00+00:00 EmrCreateJobFlowOperator 2021-04-20T08:05:47.442120+00:00 2021-04-20T08:05:49.217770+00:00 0:00:01.775650 19200 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-20T08:05:44.620515+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-20T07:05:00+00:00 PythonOperator 2021-04-20T08:05:24.980682+00:00 2021-04-20T08:05:28.778770+00:00 0:00:03.798088 19199 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-20T08:05:22.566307+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-20T07:00:00+00:00 EmrJobFlowSensor 2021-04-20T08:01:14.453264+00:00 2021-04-20T08:10:17.284788+00:00 0:09:02.831524 19198 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-20T08:01:12.042021+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-20T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-20T08:00:50.419054+00:00 2021-04-20T08:00:52.154469+00:00 0:00:01.735415 19197 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-20T08:00:48.044472+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-20T07:00:00+00:00 PythonOperator 2021-04-20T08:00:20.369022+00:00 2021-04-20T08:00:23.381308+00:00 0:00:03.012286 19196 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-20T08:00:18.000337+00:00 2 default_pool
success primary-audience-global-cassandra_v003 create_cluster 2021-04-20T07:38:36.977949+00:00 PythonOperator 2021-04-20T07:39:09.177194+00:00 2021-04-20T07:39:12.707690+00:00 0:00:03.530496 19194 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T07:39:06.989864+00:00 2 default_pool
success primary-audience-global-cassandra_v003 validation 2021-04-20T07:38:36.977949+00:00 PythonOperator 2021-04-20T07:38:47.218310+00:00 2021-04-20T07:38:47.501248+00:00 0:00:00.282938 19193 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-20T07:38:44.965827+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-20T06:00:00+00:00 EmrJobFlowSensor 2021-04-20T07:12:30.898648+00:00 2021-04-20T07:23:33.760796+00:00 0:11:02.862148 19192 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T07:12:28.151534+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-20T06:00:00+00:00 EmrJobFlowSensor 2021-04-20T07:12:28.376085+00:00 2021-04-20T07:22:31.341075+00:00 0:10:02.964990 19191 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T07:12:26.068718+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-20T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-20T07:12:08.438615+00:00 2021-04-20T07:12:10.180735+00:00 0:00:01.742120 19190 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-20T07:12:06.044726+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-20T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-20T07:12:08.477812+00:00 2021-04-20T07:12:10.375269+00:00 0:00:01.897457 19189 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-20T07:12:06.044672+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-20T06:00:00+00:00 PythonOperator 2021-04-20T07:11:48.750345+00:00 2021-04-20T07:11:51.982436+00:00 0:00:03.232091 19188 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-20T07:11:45.951800+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-20T06:00:00+00:00 PythonOperator 2021-04-20T07:11:46.254628+00:00 2021-04-20T07:11:49.682046+00:00 0:00:03.427418 19187 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-20T07:11:43.951707+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-20T06:00:00+00:00 TriggerDagRunOperator 2021-04-20T07:11:32.346290+00:00 2021-04-20T07:11:32.914577+00:00 0:00:00.568287 19186 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T07:11:29.934526+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-20T06:00:00+00:00 TriggerDagRunOperator 2021-04-20T07:11:32.209290+00:00 2021-04-20T07:11:32.686570+00:00 0:00:00.477280 19185 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T07:11:29.934562+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-20T06:05:00+00:00 EmrJobFlowSensor 2021-04-20T07:05:57.805228+00:00 2021-04-20T07:14:00.285869+00:00 0:08:02.480641 19184 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T07:05:55.537097+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-20T06:05:00+00:00 EmrCreateJobFlowOperator 2021-04-20T07:05:35.764152+00:00 2021-04-20T07:05:37.362852+00:00 0:00:01.598700 19183 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-20T07:05:33.515674+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-20T06:05:00+00:00 PythonOperator 2021-04-20T07:05:05.696231+00:00 2021-04-20T07:05:08.779825+00:00 0:00:03.083594 19182 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-20T07:05:03.489355+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-20T06:00:00+00:00 EmrJobFlowSensor 2021-04-20T07:01:05.337452+00:00 2021-04-20T07:11:08.441682+00:00 0:10:03.104230 19181 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-20T07:01:03.023348+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-20T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-20T07:00:43.496588+00:00 2021-04-20T07:00:45.596729+00:00 0:00:02.100141 19180 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-20T07:00:41.060648+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-20T06:00:00+00:00 PythonOperator 2021-04-20T07:00:15.281780+00:00 2021-04-20T07:00:18.370234+00:00 0:00:03.088454 19179 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-20T07:00:12.977592+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-20T05:00:00+00:00 EmrJobFlowSensor 2021-04-20T06:11:52.105844+00:00 2021-04-20T06:19:54.493131+00:00 0:08:02.387287 19177 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T06:11:49.938881+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-20T05:00:00+00:00 EmrJobFlowSensor 2021-04-20T06:11:34.387645+00:00 2021-04-20T06:21:37.128345+00:00 0:10:02.740700 19176 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T06:11:31.923367+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-20T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-20T06:11:32.125928+00:00 2021-04-20T06:11:33.807758+00:00 0:00:01.681830 19175 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-20T06:11:29.921483+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-20T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-20T06:11:08.222480+00:00 2021-04-20T06:11:10.480755+00:00 0:00:02.258275 19174 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-20T06:11:05.835419+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-20T05:00:00+00:00 PythonOperator 2021-04-20T06:10:56.262792+00:00 2021-04-20T06:10:59.346138+00:00 0:00:03.083346 19173 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-20T06:10:53.846802+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-20T05:00:00+00:00 PythonOperator 2021-04-20T06:10:38.225391+00:00 2021-04-20T06:10:41.774818+00:00 0:00:03.549427 19172 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-20T06:10:35.860103+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-20T05:00:00+00:00 TriggerDagRunOperator 2021-04-20T06:10:34.350077+00:00 2021-04-20T06:10:34.795090+00:00 0:00:00.445013 19171 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T06:10:31.797441+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-20T05:00:00+00:00 TriggerDagRunOperator 2021-04-20T06:10:34.071123+00:00 2021-04-20T06:10:34.621303+00:00 0:00:00.550180 19170 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T06:10:31.797404+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-20T05:05:00+00:00 EmrJobFlowSensor 2021-04-20T06:05:51.482941+00:00 2021-04-20T06:14:54.125251+00:00 0:09:02.642310 19169 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T06:05:49.299587+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-20T05:05:00+00:00 EmrCreateJobFlowOperator 2021-04-20T06:05:29.975940+00:00 2021-04-20T06:05:31.636850+00:00 0:00:01.660910 19168 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-20T06:05:27.221661+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-20T05:05:00+00:00 PythonOperator 2021-04-20T06:05:09.509999+00:00 2021-04-20T06:05:12.421801+00:00 0:00:02.911802 19167 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-20T06:05:07.195793+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-20T05:00:00+00:00 EmrJobFlowSensor 2021-04-20T06:01:07.071895+00:00 2021-04-20T06:10:09.779305+00:00 0:09:02.707410 19166 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-20T06:01:04.883650+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-20T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-20T06:00:46.976543+00:00 2021-04-20T06:00:48.783263+00:00 0:00:01.806720 19165 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-20T06:00:44.804614+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-20T05:00:00+00:00 PythonOperator 2021-04-20T06:00:25.562093+00:00 2021-04-20T06:00:28.886112+00:00 0:00:03.324019 19164 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-20T06:00:22.856485+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-20T04:00:00+00:00 EmrJobFlowSensor 2021-04-20T05:11:52.968281+00:00 2021-04-20T05:20:55.635468+00:00 0:09:02.667187 19162 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T05:11:50.595456+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-20T04:00:00+00:00 EmrJobFlowSensor 2021-04-20T05:11:49.170874+00:00 2021-04-20T05:20:51.846874+00:00 0:09:02.676000 19161 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T05:11:46.660888+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-20T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-20T05:11:32.897139+00:00 2021-04-20T05:11:34.554667+00:00 0:00:01.657528 19160 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-20T05:11:30.580108+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-20T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-20T05:11:26.978208+00:00 2021-04-20T05:11:28.805710+00:00 0:00:01.827502 19159 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-20T05:11:24.579745+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-20T04:00:00+00:00 PythonOperator 2021-04-20T05:11:10.732066+00:00 2021-04-20T05:11:14.165254+00:00 0:00:03.433188 19158 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-20T05:11:08.513402+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-20T04:00:00+00:00 PythonOperator 2021-04-20T05:11:07.203138+00:00 2021-04-20T05:11:10.198828+00:00 0:00:02.995690 19157 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-20T05:11:04.512404+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-20T04:00:00+00:00 TriggerDagRunOperator 2021-04-20T05:10:59.354149+00:00 2021-04-20T05:10:59.903186+00:00 0:00:00.549037 19156 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T05:10:56.434893+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-20T04:00:00+00:00 TriggerDagRunOperator 2021-04-20T05:10:58.790677+00:00 2021-04-20T05:10:59.548336+00:00 0:00:00.757659 19155 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T05:10:56.434857+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-20T04:05:00+00:00 EmrJobFlowSensor 2021-04-20T05:06:00.696360+00:00 2021-04-20T05:15:03.207927+00:00 0:09:02.511567 19154 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T05:05:58.261304+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-20T04:05:00+00:00 EmrCreateJobFlowOperator 2021-04-20T05:05:40.187742+00:00 2021-04-20T05:05:41.858726+00:00 0:00:01.670984 19153 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-20T05:05:38.041432+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-20T04:05:00+00:00 PythonOperator 2021-04-20T05:05:18.308779+00:00 2021-04-20T05:05:21.237399+00:00 0:00:02.928620 19152 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-20T05:05:16.019032+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-20T04:00:00+00:00 EmrJobFlowSensor 2021-04-20T05:00:51.919607+00:00 2021-04-20T05:10:54.688039+00:00 0:10:02.768432 19151 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-20T05:00:49.717671+00:00 2 default_pool