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 check_cluster_status 2021-04-03T16:00:00+00:00 EmrJobFlowSensor 2021-04-03T17:01:05.171200+00:00 2021-04-03T17:10:07.877598+00:00 0:09:02.706398 13184 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T17:01:02.882951+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-03T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T17:00:43.083559+00:00 2021-04-03T17:00:44.753500+00:00 0:00:01.669941 13183 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-03T17:00:40.791856+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-03T16:00:00+00:00 PythonOperator 2021-04-03T17:00:22.899522+00:00 2021-04-03T17:00:25.610925+00:00 0:00:02.711403 13182 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-03T17:00:20.739248+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-03T15:00:00+00:00 EmrJobFlowSensor 2021-04-03T16:26:03.409305+00:00 2021-04-03T16:35:06.058662+00:00 0:09:02.649357 13181 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T16:26:01.219221+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-03T15:00:00+00:00 EmrJobFlowSensor 2021-04-03T16:25:59.412063+00:00 2021-04-03T16:35:01.987739+00:00 0:09:02.575676 13180 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T16:25:57.214194+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-03T15:05:00+00:00 EmrJobFlowSensor 2021-04-03T16:25:45.759472+00:00 2021-04-03T16:34:48.411841+00:00 0:09:02.652369 13179 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T16:25:43.202996+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-03T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T16:25:41.630036+00:00 2021-04-03T16:25:43.333813+00:00 0:00:01.703777 13178 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T16:25:39.263494+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-03T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T16:25:33.595572+00:00 2021-04-03T16:25:35.430577+00:00 0:00:01.835005 13177 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T16:25:31.195960+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-03T15:05:00+00:00 EmrCreateJobFlowOperator 2021-04-03T16:25:24.318813+00:00 2021-04-03T16:25:26.016994+00:00 0:00:01.698181 13176 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T16:25:21.189829+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-03T15:00:00+00:00 PythonOperator 2021-04-03T16:25:20.374199+00:00 2021-04-03T16:25:23.726117+00:00 0:00:03.351918 13175 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T16:25:17.184549+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-03T15:00:00+00:00 PythonOperator 2021-04-03T16:25:11.536666+00:00 2021-04-03T16:25:14.511644+00:00 0:00:02.974978 13174 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T16:25:09.171034+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-03T15:00:00+00:00 TriggerDagRunOperator 2021-04-03T16:25:06.628031+00:00 2021-04-03T16:25:07.503383+00:00 0:00:00.875352 13173 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T16:25:00.759501+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-03T15:00:00+00:00 TriggerDagRunOperator 2021-04-03T16:25:06.571088+00:00 2021-04-03T16:25:07.164569+00:00 0:00:00.593481 13172 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T16:25:00.759514+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-03T15:05:00+00:00 PythonOperator 2021-04-03T16:25:03.790314+00:00 2021-04-03T16:25:06.719125+00:00 0:00:02.928811 13171 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T16:25:00.759469+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-03T15:00:00+00:00 EmrJobFlowSensor 2021-04-03T16:01:00.111370+00:00 2021-04-03T16:11:03.157186+00:00 0:10:03.045816 13169 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T16:00:57.427199+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-03T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T16:00:37.903110+00:00 2021-04-03T16:00:39.763757+00:00 0:00:01.860647 13168 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-03T16:00:35.401809+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-03T15:00:00+00:00 PythonOperator 2021-04-03T16:00:17.654904+00:00 2021-04-03T16:00:20.385393+00:00 0:00:02.730489 13167 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-03T16:00:15.380283+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-03T14:00:00+00:00 EmrJobFlowSensor 2021-04-03T15:11:28.291784+00:00 2021-04-03T15:20:30.845383+00:00 0:09:02.553599 13166 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T15:11:25.943318+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-03T14:00:00+00:00 EmrJobFlowSensor 2021-04-03T15:11:26.257967+00:00 2021-04-03T15:21:29.085672+00:00 0:10:02.827705 13165 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T15:11:23.947767+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-03T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T15:11:08.474186+00:00 2021-04-03T15:11:10.239197+00:00 0:00:01.765011 13164 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T15:11:05.926829+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-03T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T15:11:06.114631+00:00 2021-04-03T15:11:08.138636+00:00 0:00:02.024005 13163 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T15:11:03.926245+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-03T14:00:00+00:00 PythonOperator 2021-04-03T15:10:38.134394+00:00 2021-04-03T15:10:41.009742+00:00 0:00:02.875348 13162 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T15:10:35.896618+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-03T14:00:00+00:00 PythonOperator 2021-04-03T15:10:36.118802+00:00 2021-04-03T15:10:38.974793+00:00 0:00:02.855991 13161 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T15:10:33.893728+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-03T14:00:00+00:00 TriggerDagRunOperator 2021-04-03T15:10:14.290774+00:00 2021-04-03T15:10:14.844282+00:00 0:00:00.553508 13160 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T15:10:11.872904+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-03T14:00:00+00:00 TriggerDagRunOperator 2021-04-03T15:10:14.254982+00:00 2021-04-03T15:10:14.671178+00:00 0:00:00.416196 13159 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T15:10:11.872934+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-03T14:05:00+00:00 EmrJobFlowSensor 2021-04-03T15:05:49.660683+00:00 2021-04-03T15:14:52.120735+00:00 0:09:02.460052 13158 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T15:05:47.518269+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-03T14:05:00+00:00 EmrCreateJobFlowOperator 2021-04-03T15:05:27.968803+00:00 2021-04-03T15:05:29.711178+00:00 0:00:01.742375 13157 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T15:05:25.559574+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-03T14:05:00+00:00 PythonOperator 2021-04-03T15:05:06.349274+00:00 2021-04-03T15:05:09.050801+00:00 0:00:02.701527 13156 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T15:05:03.543889+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-03T14:00:00+00:00 EmrJobFlowSensor 2021-04-03T15:01:04.723472+00:00 2021-04-03T15:10:07.413354+00:00 0:09:02.689882 13154 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T15:01:02.408559+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-03T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T15:00:40.626950+00:00 2021-04-03T15:00:42.298926+00:00 0:00:01.671976 13153 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-03T15:00:38.378078+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-03T14:00:00+00:00 PythonOperator 2021-04-03T15:00:20.847166+00:00 2021-04-03T15:00:23.750643+00:00 0:00:02.903477 13152 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-03T15:00:18.368824+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-03T13:00:00+00:00 EmrJobFlowSensor 2021-04-03T14:13:29.893109+00:00 2021-04-03T14:21:32.410431+00:00 0:08:02.517322 13151 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T14:13:27.560122+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-03T13:00:00+00:00 EmrJobFlowSensor 2021-04-03T14:13:27.704964+00:00 2021-04-03T14:22:30.447469+00:00 0:09:02.742505 13150 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T14:13:25.481979+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-03T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T14:13:07.837208+00:00 2021-04-03T14:13:09.816266+00:00 0:00:01.979058 13149 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T14:13:05.437558+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-03T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T14:13:07.649847+00:00 2021-04-03T14:13:09.391106+00:00 0:00:01.741259 13148 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T14:13:05.437590+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-03T13:00:00+00:00 PythonOperator 2021-04-03T14:12:48.053183+00:00 2021-04-03T14:12:50.778972+00:00 0:00:02.725789 13147 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T14:12:45.419960+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-03T13:00:00+00:00 PythonOperator 2021-04-03T14:12:45.809221+00:00 2021-04-03T14:12:49.044204+00:00 0:00:03.234983 13146 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T14:12:43.415346+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-03T13:00:00+00:00 TriggerDagRunOperator 2021-04-03T14:12:30.175513+00:00 2021-04-03T14:12:30.756845+00:00 0:00:00.581332 13145 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T14:12:27.403826+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-03T13:00:00+00:00 TriggerDagRunOperator 2021-04-03T14:12:29.843628+00:00 2021-04-03T14:12:30.262540+00:00 0:00:00.418912 13144 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T14:12:27.403780+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-03T13:05:00+00:00 EmrJobFlowSensor 2021-04-03T14:05:56.926058+00:00 2021-04-03T14:14:59.557158+00:00 0:09:02.631100 13143 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T14:05:54.754751+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-03T13:05:00+00:00 EmrCreateJobFlowOperator 2021-04-03T14:05:35.110670+00:00 2021-04-03T14:05:36.884087+00:00 0:00:01.773417 13142 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T14:05:32.732815+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-03T13:05:00+00:00 PythonOperator 2021-04-03T14:05:12.973533+00:00 2021-04-03T14:05:15.632706+00:00 0:00:02.659173 13141 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T14:05:10.713488+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-03T13:00:00+00:00 EmrJobFlowSensor 2021-04-03T14:03:14.919232+00:00 2021-04-03T14:12:17.649367+00:00 0:09:02.730135 13140 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T14:03:12.527184+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-03T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T14:02:50.803336+00:00 2021-04-03T14:02:52.589801+00:00 0:00:01.786465 13139 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-03T14:02:48.496286+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-03T13:00:00+00:00 PythonOperator 2021-04-03T14:00:18.348853+00:00 2021-04-03T14:00:21.086420+00:00 0:00:02.737567 13137 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-03T14:00:16.146924+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-03T12:00:00+00:00 EmrJobFlowSensor 2021-04-03T13:11:49.645292+00:00 2021-04-03T13:20:52.369108+00:00 0:09:02.723816 13136 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T13:11:47.313189+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-03T12:00:00+00:00 EmrJobFlowSensor 2021-04-03T13:11:33.608407+00:00 2021-04-03T13:20:36.166141+00:00 0:09:02.557734 13135 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T13:11:31.300564+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-03T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T13:11:27.822368+00:00 2021-04-03T13:11:29.609085+00:00 0:00:01.786717 13134 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T13:11:25.377369+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-03T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T13:11:13.539309+00:00 2021-04-03T13:11:15.304564+00:00 0:00:01.765255 13133 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T13:11:11.273261+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-03T12:00:00+00:00 PythonOperator 2021-04-03T13:11:07.392707+00:00 2021-04-03T13:11:10.385201+00:00 0:00:02.992494 13132 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T13:11:05.271766+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-03T12:00:00+00:00 PythonOperator 2021-04-03T13:10:51.522376+00:00 2021-04-03T13:10:54.349723+00:00 0:00:02.827347 13131 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T13:10:49.257386+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-03T12:00:00+00:00 TriggerDagRunOperator 2021-04-03T13:10:43.763979+00:00 2021-04-03T13:10:44.286634+00:00 0:00:00.522655 13130 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T13:10:41.251131+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-03T12:00:00+00:00 TriggerDagRunOperator 2021-04-03T13:10:43.668133+00:00 2021-04-03T13:10:44.230560+00:00 0:00:00.562427 13129 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T13:10:41.251099+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-03T12:05:00+00:00 EmrJobFlowSensor 2021-04-03T13:05:49.196036+00:00 2021-04-03T13:14:51.689189+00:00 0:09:02.493153 13128 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T13:05:46.846503+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-03T12:05:00+00:00 EmrCreateJobFlowOperator 2021-04-03T13:05:29.037861+00:00 2021-04-03T13:05:30.763697+00:00 0:00:01.725836 13127 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T13:05:26.743569+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-03T12:05:00+00:00 PythonOperator 2021-04-03T13:05:06.955400+00:00 2021-04-03T13:05:09.634394+00:00 0:00:02.678994 13126 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T13:05:04.723138+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-03T12:00:00+00:00 EmrJobFlowSensor 2021-04-03T13:01:34.660847+00:00 2021-04-03T13:10:37.291892+00:00 0:09:02.631045 13125 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T13:01:32.436201+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-03T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T13:01:12.731903+00:00 2021-04-03T13:01:14.420882+00:00 0:00:01.688979 13124 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-03T13:01:10.381219+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-03T12:00:00+00:00 PythonOperator 2021-04-03T13:00:52.771125+00:00 2021-04-03T13:00:55.630198+00:00 0:00:02.859073 13123 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-03T13:00:50.355010+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-03T11:00:00+00:00 EmrJobFlowSensor 2021-04-03T12:11:10.214770+00:00 2021-04-03T12:21:12.949093+00:00 0:10:02.734323 13121 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T12:11:07.889322+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-03T11:00:00+00:00 EmrJobFlowSensor 2021-04-03T12:11:06.359366+00:00 2021-04-03T12:21:09.187665+00:00 0:10:02.828299 13120 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T12:11:03.956055+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-03T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T12:10:48.140251+00:00 2021-04-03T12:10:49.867189+00:00 0:00:01.726938 13119 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T12:10:45.834002+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-03T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T12:10:44.022730+00:00 2021-04-03T12:10:45.697243+00:00 0:00:01.674513 13118 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T12:10:41.830435+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-03T11:00:00+00:00 PythonOperator 2021-04-03T12:10:28.477404+00:00 2021-04-03T12:10:31.728337+00:00 0:00:03.250933 13117 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T12:10:25.814849+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-03T11:00:00+00:00 PythonOperator 2021-04-03T12:10:22.034382+00:00 2021-04-03T12:10:24.872587+00:00 0:00:02.838205 13116 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T12:10:19.810818+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-03T11:00:00+00:00 TriggerDagRunOperator 2021-04-03T12:10:18.179760+00:00 2021-04-03T12:10:18.737215+00:00 0:00:00.557455 13115 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T12:10:15.807247+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-03T11:00:00+00:00 TriggerDagRunOperator 2021-04-03T12:10:18.020949+00:00 2021-04-03T12:10:18.423106+00:00 0:00:00.402157 13114 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T12:10:15.807213+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-03T11:05:00+00:00 EmrJobFlowSensor 2021-04-03T12:05:53.551671+00:00 2021-04-03T12:14:56.105605+00:00 0:09:02.553934 13113 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T12:05:51.324827+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-03T11:05:00+00:00 EmrCreateJobFlowOperator 2021-04-03T12:05:33.698098+00:00 2021-04-03T12:05:35.452418+00:00 0:00:01.754320 13112 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T12:05:31.309352+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-03T11:05:00+00:00 PythonOperator 2021-04-03T12:05:11.683056+00:00 2021-04-03T12:05:14.505781+00:00 0:00:02.822725 13111 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T12:05:09.292086+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-03T11:00:00+00:00 EmrJobFlowSensor 2021-04-03T12:00:55.459721+00:00 2021-04-03T12:09:58.293362+00:00 0:09:02.833641 13110 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T12:00:52.940884+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-03T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T12:00:33.231197+00:00 2021-04-03T12:00:34.968728+00:00 0:00:01.737531 13109 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-03T12:00:30.866166+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-03T11:00:00+00:00 PythonOperator 2021-04-03T12:00:13.098756+00:00 2021-04-03T12:00:15.801771+00:00 0:00:02.703015 13108 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-03T12:00:10.798905+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-03T10:00:00+00:00 EmrJobFlowSensor 2021-04-03T11:12:28.196996+00:00 2021-04-03T11:21:30.925257+00:00 0:09:02.728261 13106 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T11:12:25.804551+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-03T10:00:00+00:00 EmrJobFlowSensor 2021-04-03T11:12:24.249988+00:00 2021-04-03T11:21:26.874053+00:00 0:09:02.624065 13105 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T11:12:21.800660+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-03T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T11:12:06.360455+00:00 2021-04-03T11:12:08.179488+00:00 0:00:01.819033 13104 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T11:12:03.856224+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-03T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T11:12:02.102388+00:00 2021-04-03T11:12:03.793590+00:00 0:00:01.691202 13103 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T11:11:59.782569+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-03T10:00:00+00:00 PythonOperator 2021-04-03T11:11:46.299954+00:00 2021-04-03T11:11:49.479734+00:00 0:00:03.179780 13102 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T11:11:43.752903+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-03T10:00:00+00:00 PythonOperator 2021-04-03T11:11:42.115520+00:00 2021-04-03T11:11:44.996891+00:00 0:00:02.881371 13101 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T11:11:39.762579+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-03T10:00:00+00:00 TriggerDagRunOperator 2021-04-03T11:11:18.058639+00:00 2021-04-03T11:11:18.650358+00:00 0:00:00.591719 13100 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T11:11:15.654997+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-03T10:00:00+00:00 TriggerDagRunOperator 2021-04-03T11:11:17.912331+00:00 2021-04-03T11:11:18.559014+00:00 0:00:00.646683 13099 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T11:11:15.654963+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-03T10:05:00+00:00 EmrJobFlowSensor 2021-04-03T11:05:57.382247+00:00 2021-04-03T11:14:59.950477+00:00 0:09:02.568230 13098 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T11:05:55.259055+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-03T10:05:00+00:00 EmrCreateJobFlowOperator 2021-04-03T11:05:35.484499+00:00 2021-04-03T11:05:37.110100+00:00 0:00:01.625601 13097 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T11:05:33.242068+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-03T10:05:00+00:00 PythonOperator 2021-04-03T11:05:13.491232+00:00 2021-04-03T11:05:16.286325+00:00 0:00:02.795093 13096 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T11:05:11.217058+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-03T10:00:00+00:00 EmrJobFlowSensor 2021-04-03T11:01:05.031970+00:00 2021-04-03T11:11:07.833000+00:00 0:10:02.801030 13095 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T11:01:02.814752+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-03T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T11:00:43.101160+00:00 2021-04-03T11:00:44.766341+00:00 0:00:01.665181 13094 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-03T11:00:40.795181+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-03T10:00:00+00:00 PythonOperator 2021-04-03T11:00:21.629893+00:00 2021-04-03T11:00:24.555713+00:00 0:00:02.925820 13093 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-03T11:00:18.772559+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-03T09:00:00+00:00 EmrJobFlowSensor 2021-04-03T10:10:26.592192+00:00 2021-04-03T10:20:29.364078+00:00 0:10:02.771886 13091 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T10:10:24.178286+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-03T09:00:00+00:00 EmrJobFlowSensor 2021-04-03T10:10:06.574653+00:00 2021-04-03T10:19:09.459985+00:00 0:09:02.885332 13090 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T10:10:04.098016+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-03T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T10:10:06.380536+00:00 2021-04-03T10:10:08.153962+00:00 0:00:01.773426 13089 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T10:10:04.098055+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-03T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T10:09:46.372234+00:00 2021-04-03T10:09:48.206154+00:00 0:00:01.833920 13088 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T10:09:44.074850+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-03T09:00:00+00:00 PythonOperator 2021-04-03T10:09:44.207212+00:00 2021-04-03T10:09:47.104345+00:00 0:00:02.897133 13087 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T10:09:42.071807+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-03T09:00:00+00:00 PythonOperator 2021-04-03T10:09:24.326195+00:00 2021-04-03T10:09:27.141904+00:00 0:00:02.815709 13086 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T10:09:22.053943+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-03T09:00:00+00:00 TriggerDagRunOperator 2021-04-03T10:09:18.662292+00:00 2021-04-03T10:09:19.335310+00:00 0:00:00.673018 13085 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T10:09:16.048637+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-03T09:00:00+00:00 TriggerDagRunOperator 2021-04-03T10:09:18.296803+00:00 2021-04-03T10:09:18.729698+00:00 0:00:00.432895 13084 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T10:09:16.048674+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-03T09:05:00+00:00 EmrJobFlowSensor 2021-04-03T10:05:58.230137+00:00 2021-04-03T10:15:00.958390+00:00 0:09:02.728253 13083 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T10:05:55.812243+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-03T09:05:00+00:00 EmrCreateJobFlowOperator 2021-04-03T10:05:35.961427+00:00 2021-04-03T10:05:37.593070+00:00 0:00:01.631643 13082 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T10:05:33.787686+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-03T09:05:00+00:00 PythonOperator 2021-04-03T10:05:09.906704+00:00 2021-04-03T10:05:12.593463+00:00 0:00:02.686759 13081 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T10:05:07.749429+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-03T09:00:00+00:00 EmrJobFlowSensor 2021-04-03T10:01:05.714149+00:00 2021-04-03T10:09:08.387605+00:00 0:08:02.673456 13080 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T10:01:03.342512+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-03T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T10:00:45.543173+00:00 2021-04-03T10:00:47.271738+00:00 0:00:01.728565 13079 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-03T10:00:43.251617+00:00 2 default_pool