The scheduler does not appear to be running. Last heartbeat was received .

The DAGs list may not update, and new tasks will not be scheduled.

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 trigger_dagrun_campaign-history-job_v002 2021-05-09T21:00:00+00:00 TriggerDagRunOperator 2021-05-09T22:10:24.828893+00:00 2021-05-09T22:10:25.392057+00:00 0:00:00.563164 26328 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T22:10:22.482507+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-09T21:05:00+00:00 EmrJobFlowSensor 2021-05-09T22:06:04.177585+00:00 2021-05-09T22:15:06.835417+00:00 0:09:02.657832 26327 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T22:06:02.084355+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-09T21:05:00+00:00 EmrCreateJobFlowOperator 2021-05-09T22:05:42.142544+00:00 2021-05-09T22:05:43.773090+00:00 0:00:01.630546 26326 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-09T22:05:40.042509+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-09T21:05:00+00:00 PythonOperator 2021-05-09T22:05:20.467539+00:00 2021-05-09T22:05:23.478258+00:00 0:00:03.010719 26325 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T22:05:18.071703+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-09T21:00:00+00:00 EmrJobFlowSensor 2021-05-09T22:01:03.963516+00:00 2021-05-09T22:10:06.798094+00:00 0:09:02.834578 26324 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T22:01:01.610107+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-09T21:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T22:00:37.990246+00:00 2021-05-09T22:00:39.697643+00:00 0:00:01.707397 26323 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-09T22:00:35.646351+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-09T21:00:00+00:00 PythonOperator 2021-05-09T22:00:17.902699+00:00 2021-05-09T22:00:21.009521+00:00 0:00:03.106822 26322 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-09T22:00:15.544251+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-09T20:00:00+00:00 EmrJobFlowSensor 2021-05-09T21:10:26.841751+00:00 2021-05-09T21:19:29.627164+00:00 0:09:02.785413 26320 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T21:10:24.465387+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-09T20:00:00+00:00 EmrJobFlowSensor 2021-05-09T21:10:20.715886+00:00 2021-05-09T21:20:23.558799+00:00 0:10:02.842913 26319 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T21:10:18.402764+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-09T20:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T21:10:04.808841+00:00 2021-05-09T21:10:06.582448+00:00 0:00:01.773607 26318 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-09T21:10:02.387297+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-09T20:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T21:09:58.713526+00:00 2021-05-09T21:10:00.500236+00:00 0:00:01.786710 26317 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-09T21:09:56.330639+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-09T20:00:00+00:00 PythonOperator 2021-05-09T21:09:43.081011+00:00 2021-05-09T21:09:46.512795+00:00 0:00:03.431784 26316 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T21:09:40.304655+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-09T20:00:00+00:00 PythonOperator 2021-05-09T21:09:38.582139+00:00 2021-05-09T21:09:42.543799+00:00 0:00:03.961660 26315 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T21:09:36.304083+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-09T20:00:00+00:00 TriggerDagRunOperator 2021-05-09T21:09:23.002735+00:00 2021-05-09T21:09:23.434126+00:00 0:00:00.431391 26314 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T21:09:20.352669+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-09T20:00:00+00:00 TriggerDagRunOperator 2021-05-09T21:09:22.871848+00:00 2021-05-09T21:09:23.410780+00:00 0:00:00.538932 26313 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T21:09:20.352721+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-09T20:05:00+00:00 EmrJobFlowSensor 2021-05-09T21:05:56.177767+00:00 2021-05-09T21:16:59.358723+00:00 0:11:03.180956 26312 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T21:05:53.931645+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-09T20:05:00+00:00 EmrCreateJobFlowOperator 2021-05-09T21:05:33.996570+00:00 2021-05-09T21:05:35.707051+00:00 0:00:01.710481 26311 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-09T21:05:31.910995+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-09T20:05:00+00:00 PythonOperator 2021-05-09T21:05:12.017080+00:00 2021-05-09T21:05:15.099735+00:00 0:00:03.082655 26310 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T21:05:09.894385+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-09T20:00:00+00:00 EmrJobFlowSensor 2021-05-09T21:01:11.732196+00:00 2021-05-09T21:09:14.376657+00:00 0:08:02.644461 26309 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T21:01:09.517453+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-09T20:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T21:00:45.815430+00:00 2021-05-09T21:00:47.687236+00:00 0:00:01.871806 26308 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-09T21:00:43.495213+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-09T20:00:00+00:00 PythonOperator 2021-05-09T21:00:23.733134+00:00 2021-05-09T21:00:26.954689+00:00 0:00:03.221555 26307 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-09T21:00:21.454192+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-09T19:00:00+00:00 EmrJobFlowSensor 2021-05-09T20:11:19.992787+00:00 2021-05-09T20:21:22.957996+00:00 0:10:02.965209 26305 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T20:11:17.714048+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-09T19:00:00+00:00 EmrJobFlowSensor 2021-05-09T20:11:09.960481+00:00 2021-05-09T20:21:12.793854+00:00 0:10:02.833373 26304 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T20:11:07.701559+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-09T19:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T20:10:54.271403+00:00 2021-05-09T20:10:56.099634+00:00 0:00:01.828231 26303 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-09T20:10:51.743811+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-09T19:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T20:10:49.974097+00:00 2021-05-09T20:10:51.689339+00:00 0:00:01.715242 26302 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-09T20:10:47.707590+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-09T19:00:00+00:00 PythonOperator 2021-05-09T20:10:33.925532+00:00 2021-05-09T20:10:37.022065+00:00 0:00:03.096533 26301 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T20:10:31.638028+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-09T19:00:00+00:00 PythonOperator 2021-05-09T20:10:28.124772+00:00 2021-05-09T20:10:31.436326+00:00 0:00:03.311554 26300 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T20:10:25.637098+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-09T19:00:00+00:00 TriggerDagRunOperator 2021-05-09T20:10:21.911031+00:00 2021-05-09T20:10:22.459098+00:00 0:00:00.548067 26299 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T20:10:19.630366+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-09T19:00:00+00:00 TriggerDagRunOperator 2021-05-09T20:10:21.801295+00:00 2021-05-09T20:10:22.266418+00:00 0:00:00.465123 26298 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T20:10:19.630397+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-09T19:05:00+00:00 EmrJobFlowSensor 2021-05-09T20:05:57.214211+00:00 2021-05-09T20:13:59.672090+00:00 0:08:02.457879 26297 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T20:05:55.094728+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-09T19:05:00+00:00 EmrCreateJobFlowOperator 2021-05-09T20:05:35.635140+00:00 2021-05-09T20:05:37.337229+00:00 0:00:01.702089 26296 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-09T20:05:33.144636+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-09T19:05:00+00:00 PythonOperator 2021-05-09T20:05:13.172117+00:00 2021-05-09T20:05:16.260182+00:00 0:00:03.088065 26295 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T20:05:10.988810+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-09T19:00:00+00:00 EmrJobFlowSensor 2021-05-09T20:01:04.719597+00:00 2021-05-09T20:10:07.462787+00:00 0:09:02.743190 26294 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T20:01:02.507963+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-09T19:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T20:00:42.809202+00:00 2021-05-09T20:00:44.626642+00:00 0:00:01.817440 26293 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-09T20:00:40.490357+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-09T19:00:00+00:00 PythonOperator 2021-05-09T20:00:22.538372+00:00 2021-05-09T20:00:25.665845+00:00 0:00:03.127473 26292 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-09T20:00:20.433462+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-09T18:00:00+00:00 EmrJobFlowSensor 2021-05-09T19:13:05.989347+00:00 2021-05-09T19:21:08.428800+00:00 0:08:02.439453 26291 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T19:13:03.823543+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-09T18:00:00+00:00 EmrJobFlowSensor 2021-05-09T19:12:58.146799+00:00 2021-05-09T19:23:01.105386+00:00 0:10:02.958587 26290 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T19:12:55.811221+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-09T18:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T19:12:34.145882+00:00 2021-05-09T19:12:35.959261+00:00 0:00:01.813379 26289 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-09T19:12:31.786584+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-09T18:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T19:12:34.045944+00:00 2021-05-09T19:12:35.727933+00:00 0:00:01.681989 26288 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-09T19:12:31.786614+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-09T18:00:00+00:00 PythonOperator 2021-05-09T19:12:10.463772+00:00 2021-05-09T19:12:13.512032+00:00 0:00:03.048260 26287 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T19:12:07.770257+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-09T18:00:00+00:00 PythonOperator 2021-05-09T19:12:10.320615+00:00 2021-05-09T19:12:13.648429+00:00 0:00:03.327814 26286 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T19:12:07.770286+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-09T18:00:00+00:00 TriggerDagRunOperator 2021-05-09T19:11:16.808752+00:00 2021-05-09T19:11:17.355128+00:00 0:00:00.546376 26284 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T19:11:14.551432+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-09T18:00:00+00:00 TriggerDagRunOperator 2021-05-09T19:11:16.734750+00:00 2021-05-09T19:11:17.142794+00:00 0:00:00.408044 26283 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T19:11:14.551465+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-09T18:05:00+00:00 EmrJobFlowSensor 2021-05-09T19:05:50.282981+00:00 2021-05-09T19:14:52.814987+00:00 0:09:02.532006 26282 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T19:05:48.102078+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-09T18:05:00+00:00 EmrCreateJobFlowOperator 2021-05-09T19:05:28.128675+00:00 2021-05-09T19:05:30.391703+00:00 0:00:02.263028 26281 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-09T19:05:26.020052+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-09T18:05:00+00:00 PythonOperator 2021-05-09T19:05:06.250822+00:00 2021-05-09T19:05:09.307673+00:00 0:00:03.056851 26280 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T19:05:04.069322+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-09T18:00:00+00:00 EmrJobFlowSensor 2021-05-09T19:01:04.114877+00:00 2021-05-09T19:11:06.994541+00:00 0:10:02.879664 26279 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T19:01:01.675557+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-09T18:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T19:00:41.793319+00:00 2021-05-09T19:00:43.637066+00:00 0:00:01.843747 26278 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-09T19:00:39.598568+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-09T18:00:00+00:00 PythonOperator 2021-05-09T19:00:20.016605+00:00 2021-05-09T19:00:23.138072+00:00 0:00:03.121467 26277 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-09T19:00:17.574560+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-09T17:00:00+00:00 EmrJobFlowSensor 2021-05-09T18:12:45.179021+00:00 2021-05-09T18:21:47.845396+00:00 0:09:02.666375 26276 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T18:12:42.841251+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-09T17:00:00+00:00 EmrJobFlowSensor 2021-05-09T18:12:35.044316+00:00 2021-05-09T18:22:37.940149+00:00 0:10:02.895833 26275 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T18:12:32.728075+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-09T17:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T18:12:25.084558+00:00 2021-05-09T18:12:26.911666+00:00 0:00:01.827108 26274 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-09T18:12:22.727642+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-09T17:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T18:12:15.073851+00:00 2021-05-09T18:12:16.868057+00:00 0:00:01.794206 26273 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-09T18:12:12.708010+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-09T17:00:00+00:00 PythonOperator 2021-05-09T18:12:02.874343+00:00 2021-05-09T18:12:06.152588+00:00 0:00:03.278245 26272 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T18:12:00.700398+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-09T17:00:00+00:00 PythonOperator 2021-05-09T18:11:53.149742+00:00 2021-05-09T18:11:56.504710+00:00 0:00:03.354968 26271 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T18:11:50.692752+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-09T17:00:00+00:00 TriggerDagRunOperator 2021-05-09T18:11:43.380252+00:00 2021-05-09T18:11:43.797216+00:00 0:00:00.416964 26270 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T18:11:40.563546+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-09T17:00:00+00:00 TriggerDagRunOperator 2021-05-09T18:11:43.400923+00:00 2021-05-09T18:11:43.949390+00:00 0:00:00.548467 26269 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T18:11:40.563578+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-09T17:05:00+00:00 EmrJobFlowSensor 2021-05-09T18:05:59.186846+00:00 2021-05-09T18:14:01.702809+00:00 0:08:02.515963 26267 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T18:05:57.106088+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-09T17:05:00+00:00 EmrCreateJobFlowOperator 2021-05-09T18:05:37.371614+00:00 2021-05-09T18:05:39.016838+00:00 0:00:01.645224 26266 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-09T18:05:35.154919+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-09T17:05:00+00:00 PythonOperator 2021-05-09T18:05:15.162063+00:00 2021-05-09T18:05:18.247188+00:00 0:00:03.085125 26265 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T18:05:13.003347+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-09T17:00:00+00:00 EmrJobFlowSensor 2021-05-09T18:00:50.812854+00:00 2021-05-09T18:10:53.706903+00:00 0:10:02.894049 26264 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T18:00:48.630998+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-09T17:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T18:00:29.040003+00:00 2021-05-09T18:00:30.871923+00:00 0:00:01.831920 26263 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-09T18:00:26.612496+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-09T17:00:00+00:00 PythonOperator 2021-05-09T18:00:07.022973+00:00 2021-05-09T18:00:10.110882+00:00 0:00:03.087909 26262 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-09T18:00:04.598203+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-09T16:00:00+00:00 EmrJobFlowSensor 2021-05-09T17:12:40.081154+00:00 2021-05-09T17:22:42.879296+00:00 0:10:02.798142 26261 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T17:12:37.891557+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-09T16:00:00+00:00 EmrJobFlowSensor 2021-05-09T17:12:28.178549+00:00 2021-05-09T17:21:30.770401+00:00 0:09:02.591852 26260 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T17:12:25.946234+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-09T16:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T17:12:18.415490+00:00 2021-05-09T17:12:20.254820+00:00 0:00:01.839330 26259 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-09T17:12:15.854323+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-09T16:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T17:12:08.001555+00:00 2021-05-09T17:12:09.806472+00:00 0:00:01.804917 26258 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-09T17:12:05.799539+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-09T16:00:00+00:00 PythonOperator 2021-05-09T17:11:58.182118+00:00 2021-05-09T17:12:01.488096+00:00 0:00:03.305978 26257 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T17:11:55.944583+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-09T16:00:00+00:00 PythonOperator 2021-05-09T17:11:45.870407+00:00 2021-05-09T17:11:48.931629+00:00 0:00:03.061222 26256 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T17:11:43.703378+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-09T16:00:00+00:00 TriggerDagRunOperator 2021-05-09T17:11:30.207028+00:00 2021-05-09T17:11:30.787307+00:00 0:00:00.580279 26255 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T17:11:27.691111+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-09T16:00:00+00:00 TriggerDagRunOperator 2021-05-09T17:11:30.083031+00:00 2021-05-09T17:11:30.542121+00:00 0:00:00.459090 26254 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T17:11:27.691084+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-09T16:05:00+00:00 EmrJobFlowSensor 2021-05-09T17:05:58.824385+00:00 2021-05-09T17:14:01.190078+00:00 0:08:02.365693 26252 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T17:05:56.632167+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-09T16:05:00+00:00 EmrCreateJobFlowOperator 2021-05-09T17:05:36.655682+00:00 2021-05-09T17:05:38.291485+00:00 0:00:01.635803 26251 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-09T17:05:34.613266+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-09T16:05:00+00:00 PythonOperator 2021-05-09T17:05:14.795189+00:00 2021-05-09T17:05:17.869142+00:00 0:00:03.073953 26250 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T17:05:12.594823+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-09T16:00:00+00:00 EmrJobFlowSensor 2021-05-09T17:00:58.487607+00:00 2021-05-09T17:11:01.282573+00:00 0:10:02.794966 26249 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T17:00:56.256488+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-09T16:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T17:00:38.440436+00:00 2021-05-09T17:00:40.173798+00:00 0:00:01.733362 26248 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-09T17:00:36.201696+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-09T16:00:00+00:00 PythonOperator 2021-05-09T17:00:16.328572+00:00 2021-05-09T17:00:19.382894+00:00 0:00:03.054322 26247 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-09T17:00:14.190661+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-09T15:00:00+00:00 EmrJobFlowSensor 2021-05-09T16:11:21.380688+00:00 2021-05-09T16:32:25.645258+00:00 0:21:04.264570 26246 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T16:11:19.062008+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-09T15:00:00+00:00 EmrJobFlowSensor 2021-05-09T16:11:05.237241+00:00 2021-05-09T16:21:08.161792+00:00 0:10:02.924551 26245 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T16:11:02.969870+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-09T15:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T16:11:01.033653+00:00 2021-05-09T16:11:02.809443+00:00 0:00:01.775790 26244 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-09T16:10:58.952575+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-09T15:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T16:10:45.250311+00:00 2021-05-09T16:10:47.025197+00:00 0:00:01.774886 26243 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-09T16:10:42.938203+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-09T15:00:00+00:00 PythonOperator 2021-05-09T16:10:39.192624+00:00 2021-05-09T16:10:42.272265+00:00 0:00:03.079641 26242 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T16:10:36.957478+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-09T15:00:00+00:00 PythonOperator 2021-05-09T16:10:23.641459+00:00 2021-05-09T16:10:27.110758+00:00 0:00:03.469299 26241 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T16:10:20.921679+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-09T15:00:00+00:00 TriggerDagRunOperator 2021-05-09T16:10:15.824255+00:00 2021-05-09T16:10:16.348532+00:00 0:00:00.524277 26240 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T16:10:12.747300+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-09T15:00:00+00:00 TriggerDagRunOperator 2021-05-09T16:10:15.676104+00:00 2021-05-09T16:10:16.065492+00:00 0:00:00.389388 26239 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T16:10:12.747345+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-09T15:05:00+00:00 EmrJobFlowSensor 2021-05-09T16:06:01.584845+00:00 2021-05-09T16:14:04.194765+00:00 0:08:02.609920 26237 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T16:05:58.941242+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-09T15:05:00+00:00 EmrCreateJobFlowOperator 2021-05-09T16:05:39.066703+00:00 2021-05-09T16:05:40.759946+00:00 0:00:01.693243 26236 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-09T16:05:36.689156+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-09T15:05:00+00:00 PythonOperator 2021-05-09T16:05:18.767071+00:00 2021-05-09T16:05:21.834806+00:00 0:00:03.067735 26235 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T16:05:16.679663+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-09T15:00:00+00:00 EmrJobFlowSensor 2021-05-09T16:00:58.609670+00:00 2021-05-09T16:10:01.452578+00:00 0:09:02.842908 26234 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T16:00:56.278393+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-09T15:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T16:00:38.400875+00:00 2021-05-09T16:00:40.094965+00:00 0:00:01.694090 26233 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-09T16:00:36.248751+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-09T15:00:00+00:00 PythonOperator 2021-05-09T16:00:16.471192+00:00 2021-05-09T16:00:19.589059+00:00 0:00:03.117867 26232 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-09T16:00:14.226084+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-09T14:00:00+00:00 EmrJobFlowSensor 2021-05-09T15:12:27.808752+00:00 2021-05-09T15:21:30.423430+00:00 0:09:02.614678 26231 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T15:12:25.260277+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-09T14:00:00+00:00 EmrJobFlowSensor 2021-05-09T15:12:25.506807+00:00 2021-05-09T15:22:28.695740+00:00 0:10:03.188933 26230 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T15:12:23.257582+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-09T14:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T15:12:07.296438+00:00 2021-05-09T15:12:09.029982+00:00 0:00:01.733544 26229 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-09T15:12:05.139701+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-09T14:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T15:12:05.505305+00:00 2021-05-09T15:12:07.315496+00:00 0:00:01.810191 26228 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-09T15:12:03.151715+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-09T14:00:00+00:00 PythonOperator 2021-05-09T15:11:45.382585+00:00 2021-05-09T15:11:48.540030+00:00 0:00:03.157445 26227 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T15:11:43.121436+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-09T14:00:00+00:00 PythonOperator 2021-05-09T15:11:43.285758+00:00 2021-05-09T15:11:46.582853+00:00 0:00:03.297095 26226 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T15:11:41.120763+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-09T14:00:00+00:00 TriggerDagRunOperator 2021-05-09T15:11:25.418392+00:00 2021-05-09T15:11:25.916866+00:00 0:00:00.498474 26225 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T15:11:23.103881+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-09T14:00:00+00:00 TriggerDagRunOperator 2021-05-09T15:11:25.289698+00:00 2021-05-09T15:11:25.685375+00:00 0:00:00.395677 26224 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T15:11:23.103847+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-09T14:05:00+00:00 EmrJobFlowSensor 2021-05-09T15:07:13.083742+00:00 2021-05-09T15:15:15.588066+00:00 0:08:02.504324 26223 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T15:07:10.782826+00:00 2 default_pool