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 booking-processing-job_v002 create_emr_steps 2021-05-07T05:00:00+00:00 PythonOperator 2021-05-07T06:10:16.465931+00:00 2021-05-07T06:10:19.712342+00:00 0:00:03.246411 25368 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T06:10:14.128051+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-07T05:00:00+00:00 PythonOperator 2021-05-07T06:10:06.639879+00:00 2021-05-07T06:10:09.691289+00:00 0:00:03.051410 25367 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T06:10:04.121500+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-07T05:00:00+00:00 TriggerDagRunOperator 2021-05-07T06:09:59.210699+00:00 2021-05-07T06:09:59.724251+00:00 0:00:00.513552 25366 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T06:09:56.165160+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-07T05:00:00+00:00 TriggerDagRunOperator 2021-05-07T06:09:58.589006+00:00 2021-05-07T06:09:59.002864+00:00 0:00:00.413858 25365 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T06:09:56.165203+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-07T05:05:00+00:00 EmrJobFlowSensor 2021-05-07T06:05:54.131547+00:00 2021-05-07T06:14:56.792783+00:00 0:09:02.661236 25364 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T06:05:51.570339+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-07T05:05:00+00:00 EmrCreateJobFlowOperator 2021-05-07T06:05:31.762788+00:00 2021-05-07T06:05:33.399602+00:00 0:00:01.636814 25363 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-07T06:05:29.444646+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-07T05:05:00+00:00 PythonOperator 2021-05-07T06:05:09.667379+00:00 2021-05-07T06:05:12.706316+00:00 0:00:03.038937 25362 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T06:05:07.255123+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-07T05:00:00+00:00 EmrJobFlowSensor 2021-05-07T06:00:46.933166+00:00 2021-05-07T06:09:49.750901+00:00 0:09:02.817735 25361 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T06:00:44.692807+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-07T05:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T06:00:25.077608+00:00 2021-05-07T06:00:26.904323+00:00 0:00:01.826715 25360 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-07T06:00:22.621857+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-07T05:00:00+00:00 PythonOperator 2021-05-07T06:00:04.822809+00:00 2021-05-07T06:00:07.941189+00:00 0:00:03.118380 25359 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-07T06:00:02.607341+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-07T04:00:00+00:00 EmrJobFlowSensor 2021-05-07T05:12:32.865126+00:00 2021-05-07T05:23:35.769827+00:00 0:11:02.904701 25357 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T05:12:30.450032+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-07T04:00:00+00:00 EmrJobFlowSensor 2021-05-07T05:12:26.733378+00:00 2021-05-07T05:22:29.353522+00:00 0:10:02.620144 25356 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T05:12:24.462048+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-07T04:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T05:12:10.814121+00:00 2021-05-07T05:12:12.612690+00:00 0:00:01.798569 25355 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-07T05:12:08.398575+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-07T04:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T05:12:06.492320+00:00 2021-05-07T05:12:08.226319+00:00 0:00:01.733999 25354 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-07T05:12:04.386407+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-07T04:00:00+00:00 PythonOperator 2021-05-07T05:11:50.811400+00:00 2021-05-07T05:11:53.888596+00:00 0:00:03.077196 25353 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T05:11:48.377084+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-07T04:00:00+00:00 PythonOperator 2021-05-07T05:11:44.601840+00:00 2021-05-07T05:11:47.998818+00:00 0:00:03.396978 25352 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T05:11:42.351778+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-07T04:00:00+00:00 TriggerDagRunOperator 2021-05-07T05:11:27.012111+00:00 2021-05-07T05:11:27.523150+00:00 0:00:00.511039 25351 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T05:11:24.339160+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-07T04:00:00+00:00 TriggerDagRunOperator 2021-05-07T05:11:26.759392+00:00 2021-05-07T05:11:27.180772+00:00 0:00:00.421380 25350 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T05:11:24.339130+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-07T04:05:00+00:00 EmrJobFlowSensor 2021-05-07T05:06:00.317400+00:00 2021-05-07T05:16:03.273654+00:00 0:10:02.956254 25349 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T05:05:57.850296+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-07T04:05:00+00:00 EmrCreateJobFlowOperator 2021-05-07T05:05:37.940424+00:00 2021-05-07T05:05:39.591646+00:00 0:00:01.651222 25348 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-07T05:05:35.693104+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-07T04:05:00+00:00 PythonOperator 2021-05-07T05:05:15.746423+00:00 2021-05-07T05:05:18.801419+00:00 0:00:03.054996 25347 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T05:05:13.540279+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-07T04:00:00+00:00 EmrJobFlowSensor 2021-05-07T05:00:59.393348+00:00 2021-05-07T05:11:02.313360+00:00 0:10:02.920012 25346 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T05:00:56.961134+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-07T04:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T05:00:39.265709+00:00 2021-05-07T05:00:40.914060+00:00 0:00:01.648351 25345 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-07T05:00:36.963648+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-07T04:00:00+00:00 PythonOperator 2021-05-07T05:00:17.026915+00:00 2021-05-07T05:00:20.154244+00:00 0:00:03.127329 25344 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-07T05:00:14.837603+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-07T03:00:00+00:00 EmrJobFlowSensor 2021-05-07T04:23:16.393203+00:00 2021-05-07T04:23:17.855220+00:00 0:00:01.462017 25342 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T04:23:14.245462+00:00 3 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-07T03:00:00+00:00 EmrJobFlowSensor 2021-05-07T04:23:10.631063+00:00 2021-05-07T04:23:12.196636+00:00 0:00:01.565573 25341 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T04:23:08.245812+00:00 3 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-07T03:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T04:12:03.490447+00:00 2021-05-07T04:12:05.202964+00:00 0:00:01.712517 25338 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-07T04:12:01.335767+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-07T03:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T04:11:49.704468+00:00 2021-05-07T04:11:51.541838+00:00 0:00:01.837370 25337 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-07T04:11:47.332730+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-07T03:00:00+00:00 PythonOperator 2021-05-07T04:11:39.800912+00:00 2021-05-07T04:11:42.984752+00:00 0:00:03.183840 25336 airflow-worker-2.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T04:11:37.316352+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-07T03:00:00+00:00 PythonOperator 2021-05-07T04:11:29.984032+00:00 2021-05-07T04:11:32.976595+00:00 0:00:02.992563 25335 airflow-worker-2.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T04:11:27.307661+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-07T03:00:00+00:00 TriggerDagRunOperator 2021-05-07T04:11:13.937430+00:00 2021-05-07T04:11:14.497234+00:00 0:00:00.559804 25334 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T04:11:11.345227+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-07T03:00:00+00:00 TriggerDagRunOperator 2021-05-07T04:11:13.806010+00:00 2021-05-07T04:11:14.321919+00:00 0:00:00.515909 25333 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T04:11:11.345194+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-07T03:05:00+00:00 EmrJobFlowSensor 2021-05-07T04:06:04.898533+00:00 2021-05-07T04:15:07.491819+00:00 0:09:02.593286 25332 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T04:06:02.571661+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-07T03:05:00+00:00 EmrCreateJobFlowOperator 2021-05-07T04:05:42.769464+00:00 2021-05-07T04:05:44.503343+00:00 0:00:01.733879 25331 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-07T04:05:40.495512+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-07T03:05:00+00:00 PythonOperator 2021-05-07T04:05:20.547170+00:00 2021-05-07T04:05:23.558172+00:00 0:00:03.011002 25330 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T04:05:18.468339+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-07T03:00:00+00:00 EmrJobFlowSensor 2021-05-07T04:00:46.147926+00:00 2021-05-07T04:10:49.158819+00:00 0:10:03.010893 25329 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T04:00:43.881917+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-07T03:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T04:00:26.125169+00:00 2021-05-07T04:00:27.955789+00:00 0:00:01.830620 25328 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-07T04:00:23.847428+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-07T03:00:00+00:00 PythonOperator 2021-05-07T04:00:04.484715+00:00 2021-05-07T04:00:07.545168+00:00 0:00:03.060453 25327 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-07T04:00:01.810792+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-07T02:00:00+00:00 EmrJobFlowSensor 2021-05-07T03:12:11.491308+00:00 2021-05-07T03:21:14.169723+00:00 0:09:02.678415 25325 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T03:12:09.352907+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-07T02:00:00+00:00 EmrJobFlowSensor 2021-05-07T03:12:09.822257+00:00 2021-05-07T03:21:12.597592+00:00 0:09:02.775335 25324 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T03:12:07.362011+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-07T02:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T03:11:49.470646+00:00 2021-05-07T03:11:51.137042+00:00 0:00:01.666396 25323 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-07T03:11:47.286648+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-07T02:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T03:11:47.519952+00:00 2021-05-07T03:11:49.346255+00:00 0:00:01.826303 25322 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-07T03:11:45.227368+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-07T02:00:00+00:00 PythonOperator 2021-05-07T03:11:29.727823+00:00 2021-05-07T03:11:32.973365+00:00 0:00:03.245542 25321 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T03:11:27.215393+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-07T02:00:00+00:00 PythonOperator 2021-05-07T03:11:27.313440+00:00 2021-05-07T03:11:30.736165+00:00 0:00:03.422725 25320 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T03:11:25.203905+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-07T02:00:00+00:00 TriggerDagRunOperator 2021-05-07T03:11:03.829552+00:00 2021-05-07T03:11:04.347639+00:00 0:00:00.518087 25319 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T03:11:01.187317+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-07T02:00:00+00:00 TriggerDagRunOperator 2021-05-07T03:11:03.725992+00:00 2021-05-07T03:11:04.135619+00:00 0:00:00.409627 25318 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T03:11:01.187349+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-07T02:05:00+00:00 EmrJobFlowSensor 2021-05-07T03:05:52.655014+00:00 2021-05-07T03:13:55.143642+00:00 0:08:02.488628 25317 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T03:05:50.532131+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-07T02:05:00+00:00 EmrCreateJobFlowOperator 2021-05-07T03:05:30.946660+00:00 2021-05-07T03:05:32.623144+00:00 0:00:01.676484 25316 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-07T03:05:28.668764+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-07T02:05:00+00:00 PythonOperator 2021-05-07T03:05:10.655622+00:00 2021-05-07T03:05:13.691216+00:00 0:00:03.035594 25315 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T03:05:08.490682+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-07T02:00:00+00:00 EmrJobFlowSensor 2021-05-07T03:00:48.552064+00:00 2021-05-07T03:10:51.515806+00:00 0:10:02.963742 25314 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T03:00:46.027837+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-07T02:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T03:00:26.374933+00:00 2021-05-07T03:00:28.145154+00:00 0:00:01.770221 25313 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-07T03:00:24.077616+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-07T02:00:00+00:00 PythonOperator 2021-05-07T03:00:06.763984+00:00 2021-05-07T03:00:09.832872+00:00 0:00:03.068888 25312 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-07T03:00:04.044405+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-07T01:00:00+00:00 EmrJobFlowSensor 2021-05-07T02:11:56.395053+00:00 2021-05-07T02:21:59.244630+00:00 0:10:02.849577 25310 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T02:11:53.785760+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-07T01:00:00+00:00 EmrJobFlowSensor 2021-05-07T02:11:50.318668+00:00 2021-05-07T02:21:53.248150+00:00 0:10:02.929482 25309 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T02:11:47.846530+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-07T01:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T02:11:35.998108+00:00 2021-05-07T02:11:37.756773+00:00 0:00:01.758665 25308 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-07T02:11:33.713176+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-07T01:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T02:11:27.894498+00:00 2021-05-07T02:11:29.563275+00:00 0:00:01.668777 25307 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-07T02:11:25.697824+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-07T01:00:00+00:00 PythonOperator 2021-05-07T02:11:13.909192+00:00 2021-05-07T02:11:17.201954+00:00 0:00:03.292762 25306 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T02:11:11.687651+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-07T01:00:00+00:00 PythonOperator 2021-05-07T02:11:07.880346+00:00 2021-05-07T02:11:10.893746+00:00 0:00:03.013400 25305 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T02:11:05.680218+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-07T01:00:00+00:00 TriggerDagRunOperator 2021-05-07T02:10:46.000975+00:00 2021-05-07T02:10:46.560726+00:00 0:00:00.559751 25304 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T02:10:43.605637+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-07T01:00:00+00:00 TriggerDagRunOperator 2021-05-07T02:10:45.958512+00:00 2021-05-07T02:10:46.399890+00:00 0:00:00.441378 25303 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T02:10:43.605607+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-07T01:05:00+00:00 EmrJobFlowSensor 2021-05-07T02:05:55.149320+00:00 2021-05-07T02:14:57.790950+00:00 0:09:02.641630 25302 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T02:05:52.926754+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-07T01:05:00+00:00 EmrCreateJobFlowOperator 2021-05-07T02:05:33.322889+00:00 2021-05-07T02:05:35.066427+00:00 0:00:01.743538 25301 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-07T02:05:30.910417+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-07T01:05:00+00:00 PythonOperator 2021-05-07T02:05:10.945403+00:00 2021-05-07T02:05:14.098454+00:00 0:00:03.153051 25300 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T02:05:08.900603+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-07T01:00:00+00:00 EmrJobFlowSensor 2021-05-07T02:01:12.760957+00:00 2021-05-07T02:10:15.509364+00:00 0:09:02.748407 25299 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T02:01:10.436481+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-07T01:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T02:00:46.684807+00:00 2021-05-07T02:00:48.514293+00:00 0:00:01.829486 25298 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-07T02:00:44.412634+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-07T01:00:00+00:00 PythonOperator 2021-05-07T02:00:16.588683+00:00 2021-05-07T02:00:19.654419+00:00 0:00:03.065736 25297 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-07T02:00:14.402966+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-07T00:00:00+00:00 EmrJobFlowSensor 2021-05-07T01:11:03.142078+00:00 2021-05-07T01:21:05.980232+00:00 0:10:02.838154 25295 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T01:11:00.344295+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-07T00:00:00+00:00 EmrJobFlowSensor 2021-05-07T01:11:01.011304+00:00 2021-05-07T01:21:04.183693+00:00 0:10:03.172389 25294 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T01:10:58.460808+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-07T00:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T01:10:40.501956+00:00 2021-05-07T01:10:42.295663+00:00 0:00:01.793707 25293 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-07T01:10:38.250359+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-07T00:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T01:10:38.379861+00:00 2021-05-07T01:10:40.100451+00:00 0:00:01.720590 25292 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-07T01:10:36.241410+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-07T00:00:00+00:00 PythonOperator 2021-05-07T01:10:20.394950+00:00 2021-05-07T01:10:23.620727+00:00 0:00:03.225777 25291 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T01:10:18.224678+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-07T00:00:00+00:00 PythonOperator 2021-05-07T01:10:18.587678+00:00 2021-05-07T01:10:21.699461+00:00 0:00:03.111783 25290 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T01:10:16.226982+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-07T00:00:00+00:00 TriggerDagRunOperator 2021-05-07T01:10:04.604211+00:00 2021-05-07T01:10:05.090769+00:00 0:00:00.486558 25289 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T01:10:02.208436+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-07T00:00:00+00:00 TriggerDagRunOperator 2021-05-07T01:10:04.322540+00:00 2021-05-07T01:10:04.730207+00:00 0:00:00.407667 25288 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T01:10:02.208466+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-07T00:05:00+00:00 EmrJobFlowSensor 2021-05-07T01:05:56.064918+00:00 2021-05-07T01:14:58.681952+00:00 0:09:02.617034 25287 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T01:05:53.932099+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-07T00:05:00+00:00 EmrCreateJobFlowOperator 2021-05-07T01:05:34.388316+00:00 2021-05-07T01:05:36.134960+00:00 0:00:01.746644 25286 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-07T01:05:31.913007+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-07T00:05:00+00:00 PythonOperator 2021-05-07T01:05:10.289731+00:00 2021-05-07T01:05:13.412016+00:00 0:00:03.122285 25285 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T01:05:07.890536+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-07T00:00:00+00:00 EmrJobFlowSensor 2021-05-07T01:00:57.939105+00:00 2021-05-07T01:10:00.674452+00:00 0:09:02.735347 25284 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T01:00:55.650948+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-07T00:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T01:00:37.773234+00:00 2021-05-07T01:00:39.476935+00:00 0:00:01.703701 25283 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-07T01:00:35.542625+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-07T00:00:00+00:00 PythonOperator 2021-05-07T01:00:15.801814+00:00 2021-05-07T01:00:18.890803+00:00 0:00:03.088989 25282 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-07T01:00:13.522972+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-06T23:00:00+00:00 EmrJobFlowSensor 2021-05-07T00:11:29.116028+00:00 2021-05-07T00:20:31.754706+00:00 0:09:02.638678 25280 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T00:11:26.988687+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-06T23:00:00+00:00 EmrJobFlowSensor 2021-05-07T00:11:11.194291+00:00 2021-05-07T00:20:13.799730+00:00 0:09:02.605439 25279 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T00:11:08.971315+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-06T23:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T00:11:07.235687+00:00 2021-05-07T00:11:09.093936+00:00 0:00:01.858249 25278 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-07T00:11:04.968516+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-06T23:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T00:10:49.281995+00:00 2021-05-07T00:10:51.090763+00:00 0:00:01.808768 25277 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-07T00:10:46.922279+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-06T23:00:00+00:00 PythonOperator 2021-05-07T00:10:45.399363+00:00 2021-05-07T00:10:48.435847+00:00 0:00:03.036484 25276 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T00:10:42.966454+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-06T23:00:00+00:00 PythonOperator 2021-05-07T00:10:27.520289+00:00 2021-05-07T00:10:30.739364+00:00 0:00:03.219075 25275 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T00:10:24.966636+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-06T23:00:00+00:00 TriggerDagRunOperator 2021-05-07T00:10:21.133368+00:00 2021-05-07T00:10:21.655646+00:00 0:00:00.522278 25274 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T00:10:18.900566+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-06T23:00:00+00:00 TriggerDagRunOperator 2021-05-07T00:10:20.990580+00:00 2021-05-07T00:10:21.444943+00:00 0:00:00.454363 25273 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T00:10:18.900529+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-06T23:05:00+00:00 EmrJobFlowSensor 2021-05-07T00:05:58.682914+00:00 2021-05-07T00:14:01.122042+00:00 0:08:02.439128 25272 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T00:05:56.591997+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-06T23:05:00+00:00 EmrCreateJobFlowOperator 2021-05-07T00:05:36.657498+00:00 2021-05-07T00:05:38.318487+00:00 0:00:01.660989 25271 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-07T00:05:34.539270+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-06T23:05:00+00:00 PythonOperator 2021-05-07T00:05:16.583671+00:00 2021-05-07T00:05:19.613647+00:00 0:00:03.029976 25270 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T00:05:14.524533+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-06T23:00:00+00:00 EmrJobFlowSensor 2021-05-07T00:01:04.403298+00:00 2021-05-07T00:10:07.129011+00:00 0:09:02.725713 25269 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T00:01:02.229241+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-06T23:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T00:00:42.450461+00:00 2021-05-07T00:00:44.320463+00:00 0:00:01.870002 25268 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-07T00:00:40.207698+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-06T23:00:00+00:00 PythonOperator 2021-05-07T00:00:20.724369+00:00 2021-05-07T00:00:23.875370+00:00 0:00:03.151001 25267 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-07T00:00:18.187445+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-06T22:05:00+00:00 EmrJobFlowSensor 2021-05-06T23:15:40.289088+00:00 2021-05-06T23:15:41.805473+00:00 0:00:01.516385 25265 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T23:15:38.077514+00:00 3 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-06T22:00:00+00:00 EmrJobFlowSensor 2021-05-06T23:11:34.578690+00:00 2021-05-06T23:22:37.632732+00:00 0:11:03.054042 25264 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T23:11:31.858095+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-06T22:00:00+00:00 EmrJobFlowSensor 2021-05-06T23:11:34.403969+00:00 2021-05-06T23:20:37.052142+00:00 0:09:02.648173 25263 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T23:11:31.858139+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-06T22:00:00+00:00 EmrCreateJobFlowOperator 2021-05-06T23:11:14.293754+00:00 2021-05-06T23:11:16.111620+00:00 0:00:01.817866 25262 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-06T23:11:11.867049+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-06T22:00:00+00:00 EmrCreateJobFlowOperator 2021-05-06T23:11:12.056609+00:00 2021-05-06T23:11:13.765075+00:00 0:00:01.708466 25261 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-06T23:11:09.850502+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-06T22:00:00+00:00 PythonOperator 2021-05-06T23:10:52.036871+00:00 2021-05-06T23:10:55.086775+00:00 0:00:03.049904 25260 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T23:10:49.741967+00:00 2 default_pool