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

Reset Filters
  State Dag Id Task Id Execution Date Operator Start Date End Date Duration Job Id Hostname Unixname Priority Weight Queue Queued Dttm Try Number Pool Log Url
success campaign-flow-job_v002 create_emr_steps 2021-04-09T17:00:00+00:00 PythonOperator 2021-04-09T18:00:22.053726+00:00 2021-04-09T18:00:24.947225+00:00 0:00:02.893499 15360 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-09T18:00:19.743650+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-09T16:00:00+00:00 TriggerDagRunOperator 2021-04-09T17:10:15.733924+00:00 2021-04-09T17:10:16.259805+00:00 0:00:00.525881 15353 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T17:10:12.641007+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-09T16:00:00+00:00 TriggerDagRunOperator 2021-04-09T17:10:15.626847+00:00 2021-04-09T17:10:16.036759+00:00 0:00:00.409912 15352 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T17:10:12.641053+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-09T16:00:00+00:00 EmrJobFlowSensor 2021-04-09T17:00:49.443467+00:00 2021-04-09T17:09:52.167398+00:00 0:09:02.723931 15347 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T17:00:46.461496+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-09T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T17:00:28.824629+00:00 2021-04-09T17:00:30.636945+00:00 0:00:01.812316 15346 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-09T17:00:26.415990+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-09T16:00:00+00:00 PythonOperator 2021-04-09T17:00:06.663325+00:00 2021-04-09T17:00:09.802737+00:00 0:00:03.139412 15345 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-09T17:00:04.386875+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-09T15:00:00+00:00 TriggerDagRunOperator 2021-04-09T16:18:31.167631+00:00 2021-04-09T16:18:31.890748+00:00 0:00:00.723117 15338 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T16:18:28.218466+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-09T15:00:00+00:00 TriggerDagRunOperator 2021-04-09T16:18:30.664329+00:00 2021-04-09T16:18:31.108684+00:00 0:00:00.444355 15337 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T16:18:28.218430+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-09T15:00:00+00:00 EmrJobFlowSensor 2021-04-09T16:09:15.767339+00:00 2021-04-09T16:18:18.437947+00:00 0:09:02.670608 15335 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T16:09:13.498999+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-09T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T16:08:55.644023+00:00 2021-04-09T16:08:57.318368+00:00 0:00:01.674345 15333 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-09T16:08:53.457321+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-09T15:00:00+00:00 PythonOperator 2021-04-09T16:08:34.524150+00:00 2021-04-09T16:08:37.331113+00:00 0:00:02.806963 15331 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-09T16:08:31.439296+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-09T14:00:00+00:00 TriggerDagRunOperator 2021-04-09T15:11:06.106027+00:00 2021-04-09T15:11:06.667743+00:00 0:00:00.561716 15323 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T15:11:03.800947+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-09T14:00:00+00:00 TriggerDagRunOperator 2021-04-09T15:11:06.085162+00:00 2021-04-09T15:11:06.572734+00:00 0:00:00.487572 15322 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T15:11:03.800893+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-09T14:00:00+00:00 EmrJobFlowSensor 2021-04-09T15:00:49.214916+00:00 2021-04-09T15:10:52.081135+00:00 0:10:02.866219 15318 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T15:00:46.784833+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-09T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T15:00:29.053646+00:00 2021-04-09T15:00:30.888915+00:00 0:00:01.835269 15317 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-09T15:00:26.734790+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-09T14:00:00+00:00 PythonOperator 2021-04-09T15:00:07.535390+00:00 2021-04-09T15:00:10.586560+00:00 0:00:03.051170 15316 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-09T15:00:04.712384+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-09T13:00:00+00:00 TriggerDagRunOperator 2021-04-09T14:11:04.673178+00:00 2021-04-09T14:11:05.215760+00:00 0:00:00.542582 15308 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T14:11:02.287389+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-09T13:00:00+00:00 TriggerDagRunOperator 2021-04-09T14:11:04.611048+00:00 2021-04-09T14:11:05.031089+00:00 0:00:00.420041 15307 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T14:11:02.287434+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-09T13:00:00+00:00 EmrJobFlowSensor 2021-04-09T14:00:57.513969+00:00 2021-04-09T14:11:00.290016+00:00 0:10:02.776047 15303 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T14:00:55.299743+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-09T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T14:00:35.778543+00:00 2021-04-09T14:00:37.493871+00:00 0:00:01.715328 15302 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-09T14:00:33.288842+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-09T13:00:00+00:00 PythonOperator 2021-04-09T14:00:13.617261+00:00 2021-04-09T14:00:16.512679+00:00 0:00:02.895418 15301 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-09T14:00:11.220087+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-09T12:00:00+00:00 TriggerDagRunOperator 2021-04-09T13:11:22.062000+00:00 2021-04-09T13:11:22.689643+00:00 0:00:00.627643 15293 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T13:11:19.734800+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-09T12:00:00+00:00 TriggerDagRunOperator 2021-04-09T13:11:22.016637+00:00 2021-04-09T13:11:22.416943+00:00 0:00:00.400306 15292 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T13:11:19.734772+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-09T12:00:00+00:00 EmrJobFlowSensor 2021-04-09T13:01:02.904624+00:00 2021-04-09T13:11:05.772717+00:00 0:10:02.868093 15288 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T13:01:00.588824+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-09T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T13:00:40.808260+00:00 2021-04-09T13:00:42.588141+00:00 0:00:01.779881 15287 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-09T13:00:38.577123+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-09T12:00:00+00:00 PythonOperator 2021-04-09T13:00:18.970785+00:00 2021-04-09T13:00:21.848020+00:00 0:00:02.877235 15286 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-09T13:00:16.501153+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-09T11:00:00+00:00 TriggerDagRunOperator 2021-04-09T12:09:21.574147+00:00 2021-04-09T12:09:22.043435+00:00 0:00:00.469288 15278 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T12:09:19.199429+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-09T11:00:00+00:00 TriggerDagRunOperator 2021-04-09T12:09:21.496148+00:00 2021-04-09T12:09:22.033878+00:00 0:00:00.537730 15277 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T12:09:19.199391+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-09T11:00:00+00:00 EmrJobFlowSensor 2021-04-09T12:01:00.852703+00:00 2021-04-09T12:09:03.417768+00:00 0:08:02.565065 15273 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T12:00:58.453271+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-09T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T12:00:38.829211+00:00 2021-04-09T12:00:40.534298+00:00 0:00:01.705087 15272 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-09T12:00:36.367976+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-09T11:00:00+00:00 PythonOperator 2021-04-09T12:00:16.841200+00:00 2021-04-09T12:00:19.691478+00:00 0:00:02.850278 15271 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-09T12:00:14.366310+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-09T10:00:00+00:00 TriggerDagRunOperator 2021-04-09T11:10:40.090855+00:00 2021-04-09T11:10:40.547283+00:00 0:00:00.456428 15263 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T11:10:37.434516+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-09T10:00:00+00:00 TriggerDagRunOperator 2021-04-09T11:10:40.090632+00:00 2021-04-09T11:10:40.659770+00:00 0:00:00.569138 15262 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T11:10:37.434480+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-09T10:00:00+00:00 EmrJobFlowSensor 2021-04-09T11:01:13.087601+00:00 2021-04-09T11:10:15.905736+00:00 0:09:02.818135 15258 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T11:01:10.572700+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-09T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T11:00:42.771129+00:00 2021-04-09T11:00:44.532153+00:00 0:00:01.761024 15257 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-09T11:00:40.499295+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-09T10:00:00+00:00 PythonOperator 2021-04-09T11:00:19.018399+00:00 2021-04-09T11:00:21.841059+00:00 0:00:02.822660 15256 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-09T11:00:16.409727+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-09T09:00:00+00:00 TriggerDagRunOperator 2021-04-09T10:10:28.085789+00:00 2021-04-09T10:10:28.617363+00:00 0:00:00.531574 15248 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T10:10:25.482998+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-09T09:00:00+00:00 TriggerDagRunOperator 2021-04-09T10:10:27.923973+00:00 2021-04-09T10:10:28.309864+00:00 0:00:00.385891 15247 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T10:10:25.483027+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-09T09:00:00+00:00 EmrJobFlowSensor 2021-04-09T10:01:06.879768+00:00 2021-04-09T10:10:09.552830+00:00 0:09:02.673062 15243 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T10:01:04.443776+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-09T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T10:00:42.722020+00:00 2021-04-09T10:00:44.542082+00:00 0:00:01.820062 15242 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-09T10:00:40.423159+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-09T09:00:00+00:00 PythonOperator 2021-04-09T10:00:22.722811+00:00 2021-04-09T10:00:25.505018+00:00 0:00:02.782207 15241 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-09T10:00:20.411017+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-09T08:00:00+00:00 TriggerDagRunOperator 2021-04-09T09:10:17.032487+00:00 2021-04-09T09:10:17.457444+00:00 0:00:00.424957 15233 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T09:10:14.523618+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-09T08:00:00+00:00 TriggerDagRunOperator 2021-04-09T09:10:17.046331+00:00 2021-04-09T09:10:17.602514+00:00 0:00:00.556183 15232 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T09:10:14.523654+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-09T08:00:00+00:00 EmrJobFlowSensor 2021-04-09T09:00:55.902274+00:00 2021-04-09T09:09:58.686677+00:00 0:09:02.784403 15228 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T09:00:53.521297+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-09T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T09:00:31.925006+00:00 2021-04-09T09:00:33.614555+00:00 0:00:01.689549 15227 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-09T09:00:29.560469+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-09T08:00:00+00:00 PythonOperator 2021-04-09T09:00:10.115129+00:00 2021-04-09T09:00:12.868951+00:00 0:00:02.753822 15226 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-09T09:00:07.469512+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-09T07:00:00+00:00 TriggerDagRunOperator 2021-04-09T08:09:21.062459+00:00 2021-04-09T08:09:21.573360+00:00 0:00:00.510901 15218 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T08:09:18.731725+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-09T07:00:00+00:00 TriggerDagRunOperator 2021-04-09T08:09:20.917672+00:00 2021-04-09T08:09:21.330748+00:00 0:00:00.413076 15217 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T08:09:18.731681+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-09T07:00:00+00:00 EmrJobFlowSensor 2021-04-09T08:01:02.290996+00:00 2021-04-09T08:09:04.995338+00:00 0:08:02.704342 15213 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T08:00:59.894112+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-09T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T08:00:40.179261+00:00 2021-04-09T08:00:42.036689+00:00 0:00:01.857428 15212 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-09T08:00:37.874346+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-09T07:00:00+00:00 PythonOperator 2021-04-09T08:00:20.405195+00:00 2021-04-09T08:00:23.270270+00:00 0:00:02.865075 15211 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-09T08:00:17.858127+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-09T06:00:00+00:00 TriggerDagRunOperator 2021-04-09T07:09:09.519675+00:00 2021-04-09T07:09:10.048206+00:00 0:00:00.528531 15203 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T07:09:07.137584+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-09T06:00:00+00:00 TriggerDagRunOperator 2021-04-09T07:09:09.411847+00:00 2021-04-09T07:09:09.836986+00:00 0:00:00.425139 15202 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T07:09:07.137556+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-09T06:00:00+00:00 EmrJobFlowSensor 2021-04-09T07:00:50.529224+00:00 2021-04-09T07:08:53.169281+00:00 0:08:02.640057 15198 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T07:00:48.296465+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-09T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T07:00:30.745367+00:00 2021-04-09T07:00:32.520161+00:00 0:00:01.774794 15197 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-09T07:00:28.366400+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-09T06:00:00+00:00 PythonOperator 2021-04-09T07:00:08.902419+00:00 2021-04-09T07:00:11.754427+00:00 0:00:02.852008 15196 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-09T07:00:06.243605+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-09T05:00:00+00:00 TriggerDagRunOperator 2021-04-09T06:11:06.999501+00:00 2021-04-09T06:11:07.553007+00:00 0:00:00.553506 15188 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T06:11:04.256142+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-09T05:00:00+00:00 TriggerDagRunOperator 2021-04-09T06:11:06.669046+00:00 2021-04-09T06:11:07.161902+00:00 0:00:00.492856 15187 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T06:11:04.256110+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-09T05:00:00+00:00 EmrJobFlowSensor 2021-04-09T06:00:55.671521+00:00 2021-04-09T06:10:58.531515+00:00 0:10:02.859994 15183 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T06:00:53.224595+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-09T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T06:00:35.538917+00:00 2021-04-09T06:00:37.245314+00:00 0:00:01.706397 15182 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-09T06:00:33.213814+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-09T05:00:00+00:00 PythonOperator 2021-04-09T06:00:13.514450+00:00 2021-04-09T06:00:16.300855+00:00 0:00:02.786405 15181 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-09T06:00:11.190325+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-09T04:00:00+00:00 TriggerDagRunOperator 2021-04-09T05:10:17.600422+00:00 2021-04-09T05:10:18.122293+00:00 0:00:00.521871 15173 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T05:10:15.111916+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-09T04:00:00+00:00 TriggerDagRunOperator 2021-04-09T05:10:17.279832+00:00 2021-04-09T05:10:17.717649+00:00 0:00:00.437817 15172 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T05:10:15.111951+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-09T04:00:00+00:00 EmrJobFlowSensor 2021-04-09T05:00:52.230187+00:00 2021-04-09T05:09:54.951544+00:00 0:09:02.721357 15168 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T05:00:49.983399+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-09T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T05:00:32.119843+00:00 2021-04-09T05:00:33.867925+00:00 0:00:01.748082 15167 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-09T05:00:29.930392+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-09T04:00:00+00:00 PythonOperator 2021-04-09T05:00:10.547747+00:00 2021-04-09T05:00:13.401389+00:00 0:00:02.853642 15166 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-09T05:00:07.909833+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-09T03:00:00+00:00 TriggerDagRunOperator 2021-04-09T04:11:19.698583+00:00 2021-04-09T04:11:20.125730+00:00 0:00:00.427147 15158 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T04:11:17.250341+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-09T03:00:00+00:00 TriggerDagRunOperator 2021-04-09T04:11:19.681283+00:00 2021-04-09T04:11:20.250171+00:00 0:00:00.568888 15157 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T04:11:17.250372+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-09T03:00:00+00:00 EmrJobFlowSensor 2021-04-09T04:01:06.451758+00:00 2021-04-09T04:11:09.548992+00:00 0:10:03.097234 15153 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T04:01:04.173961+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-09T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T04:00:44.415167+00:00 2021-04-09T04:00:46.234023+00:00 0:00:01.818856 15152 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-09T04:00:42.091940+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-09T03:00:00+00:00 PythonOperator 2021-04-09T04:00:24.622604+00:00 2021-04-09T04:00:27.503346+00:00 0:00:02.880742 15151 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-09T04:00:22.026690+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-09T02:00:00+00:00 TriggerDagRunOperator 2021-04-09T03:10:25.055829+00:00 2021-04-09T03:10:25.530826+00:00 0:00:00.474997 15143 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T03:10:22.655076+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-09T02:00:00+00:00 TriggerDagRunOperator 2021-04-09T03:10:25.021872+00:00 2021-04-09T03:10:25.604240+00:00 0:00:00.582368 15142 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T03:10:22.655039+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-09T02:00:00+00:00 EmrJobFlowSensor 2021-04-09T03:01:07.985293+00:00 2021-04-09T03:10:10.597446+00:00 0:09:02.612153 15138 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T03:01:05.725717+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-09T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T03:00:46.209521+00:00 2021-04-09T03:00:48.052264+00:00 0:00:01.842743 15137 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-09T03:00:43.750094+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-09T02:00:00+00:00 PythonOperator 2021-04-09T03:00:24.266614+00:00 2021-04-09T03:00:26.947937+00:00 0:00:02.681323 15136 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-09T03:00:21.743750+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-09T01:00:00+00:00 TriggerDagRunOperator 2021-04-09T02:09:03.890452+00:00 2021-04-09T02:09:04.414033+00:00 0:00:00.523581 15128 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T02:09:01.274230+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-09T01:00:00+00:00 TriggerDagRunOperator 2021-04-09T02:09:03.500958+00:00 2021-04-09T02:09:03.911948+00:00 0:00:00.410990 15127 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T02:09:01.274265+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-09T01:00:00+00:00 EmrJobFlowSensor 2021-04-09T02:00:55.022812+00:00 2021-04-09T02:08:57.621203+00:00 0:08:02.598391 15123 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T02:00:52.458160+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-09T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T02:00:34.858194+00:00 2021-04-09T02:00:36.552874+00:00 0:00:01.694680 15122 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-09T02:00:32.442721+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-09T01:00:00+00:00 PythonOperator 2021-04-09T02:00:13.033930+00:00 2021-04-09T02:00:15.872045+00:00 0:00:02.838115 15121 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-09T02:00:10.263626+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-09T00:00:00+00:00 TriggerDagRunOperator 2021-04-09T01:11:13.589050+00:00 2021-04-09T01:11:14.049202+00:00 0:00:00.460152 15113 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T01:11:11.050618+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-09T00:00:00+00:00 TriggerDagRunOperator 2021-04-09T01:11:13.514524+00:00 2021-04-09T01:11:14.162968+00:00 0:00:00.648444 15112 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T01:11:11.050591+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-09T00:00:00+00:00 EmrJobFlowSensor 2021-04-09T01:00:58.166523+00:00 2021-04-09T01:11:01.032259+00:00 0:10:02.865736 15108 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T01:00:55.910840+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-09T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T01:00:36.144249+00:00 2021-04-09T01:00:37.928153+00:00 0:00:01.783904 15107 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-09T01:00:33.888765+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-09T00:00:00+00:00 PythonOperator 2021-04-09T01:00:16.820113+00:00 2021-04-09T01:00:19.522336+00:00 0:00:02.702223 15106 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-09T01:00:13.762819+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-08T23:00:00+00:00 TriggerDagRunOperator 2021-04-09T00:09:06.106899+00:00 2021-04-09T00:09:06.545387+00:00 0:00:00.438488 15098 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T00:09:03.678749+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-08T23:00:00+00:00 TriggerDagRunOperator 2021-04-09T00:09:05.976528+00:00 2021-04-09T00:09:06.614499+00:00 0:00:00.637971 15097 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T00:09:03.678782+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-08T23:00:00+00:00 EmrJobFlowSensor 2021-04-09T00:00:47.081544+00:00 2021-04-09T00:08:49.701051+00:00 0:08:02.619507 15093 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T00:00:44.799181+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-08T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T00:00:24.879056+00:00 2021-04-09T00:00:26.561157+00:00 0:00:01.682101 15092 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-09T00:00:22.708498+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-08T23:00:00+00:00 PythonOperator 2021-04-09T00:00:05.328628+00:00 2021-04-09T00:00:08.207131+00:00 0:00:02.878503 15091 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-09T00:00:02.698983+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-08T22:00:00+00:00 TriggerDagRunOperator 2021-04-08T23:10:21.225197+00:00 2021-04-08T23:10:21.771423+00:00 0:00:00.546226 15083 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T23:10:18.901110+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-08T22:00:00+00:00 TriggerDagRunOperator 2021-04-08T23:10:21.101956+00:00 2021-04-08T23:10:21.576649+00:00 0:00:00.474693 15082 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T23:10:18.901186+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-08T22:00:00+00:00 EmrJobFlowSensor 2021-04-08T23:01:04.433438+00:00 2021-04-08T23:10:07.213894+00:00 0:09:02.780456 15078 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T23:01:02.050524+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-08T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T23:00:42.241972+00:00 2021-04-08T23:00:44.206201+00:00 0:00:01.964229 15077 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-08T23:00:39.962505+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-08T22:00:00+00:00 PythonOperator 2021-04-08T23:00:20.611094+00:00 2021-04-08T23:00:23.341029+00:00 0:00:02.729935 15076 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-08T23:00:17.942323+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-08T21:00:00+00:00 TriggerDagRunOperator 2021-04-08T22:10:30.860219+00:00 2021-04-08T22:10:31.383983+00:00 0:00:00.523764 15068 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T22:10:28.169756+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-08T21:00:00+00:00 TriggerDagRunOperator 2021-04-08T22:10:30.762486+00:00 2021-04-08T22:10:31.178177+00:00 0:00:00.415691 15067 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T22:10:28.169791+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-08T21:00:00+00:00 EmrJobFlowSensor 2021-04-08T22:01:05.439674+00:00 2021-04-08T22:10:08.238098+00:00 0:09:02.798424 15063 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T22:01:03.081785+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-08T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T22:00:43.329319+00:00 2021-04-08T22:00:45.114754+00:00 0:00:01.785435 15062 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-08T22:00:41.016586+00:00 2 default_pool