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 booking-processing-job_v002 create_emr_steps 2021-04-04T09:00:00+00:00 PythonOperator 2021-04-04T10:10:40.091859+00:00 2021-04-04T10:10:43.185132+00:00 0:00:03.093273 13448 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T10:10:37.654307+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-04T09:00:00+00:00 TriggerDagRunOperator 2021-04-04T10:10:26.087166+00:00 2021-04-04T10:10:26.538761+00:00 0:00:00.451595 13447 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T10:10:23.685384+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-04T09:00:00+00:00 TriggerDagRunOperator 2021-04-04T10:10:25.998394+00:00 2021-04-04T10:10:26.585282+00:00 0:00:00.586888 13446 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T10:10:23.685419+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-04T09:05:00+00:00 EmrJobFlowSensor 2021-04-04T10:05:57.497442+00:00 2021-04-04T10:15:00.109609+00:00 0:09:02.612167 13445 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T10:05:55.291410+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-04T09:05:00+00:00 EmrCreateJobFlowOperator 2021-04-04T10:05:35.587491+00:00 2021-04-04T10:05:37.314041+00:00 0:00:01.726550 13444 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T10:05:33.219525+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-04T09:05:00+00:00 PythonOperator 2021-04-04T10:05:13.389694+00:00 2021-04-04T10:05:16.079990+00:00 0:00:02.690296 13443 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T10:05:11.193308+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-04T09:00:00+00:00 EmrJobFlowSensor 2021-04-04T10:01:14.847876+00:00 2021-04-04T10:10:17.620397+00:00 0:09:02.772521 13442 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T10:01:12.508789+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-04T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T10:00:54.799794+00:00 2021-04-04T10:00:56.581350+00:00 0:00:01.781556 13441 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-04T10:00:52.449908+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-04T09:00:00+00:00 PythonOperator 2021-04-04T10:00:22.815828+00:00 2021-04-04T10:00:25.590785+00:00 0:00:02.774957 13440 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-04T10:00:20.421534+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-04T08:00:00+00:00 EmrJobFlowSensor 2021-04-04T09:11:07.365009+00:00 2021-04-04T09:20:09.996243+00:00 0:09:02.631234 13438 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T09:11:05.113517+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-04T08:00:00+00:00 EmrJobFlowSensor 2021-04-04T09:10:53.586439+00:00 2021-04-04T09:20:56.267662+00:00 0:10:02.681223 13437 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T09:10:51.102321+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-04T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T09:10:45.313721+00:00 2021-04-04T09:10:46.973079+00:00 0:00:01.659358 13436 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T09:10:43.098114+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-04T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T09:10:29.655529+00:00 2021-04-04T09:10:31.329546+00:00 0:00:01.674017 13435 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T09:10:27.153529+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-04T08:00:00+00:00 PythonOperator 2021-04-04T09:10:23.312322+00:00 2021-04-04T09:10:26.098052+00:00 0:00:02.785730 13434 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T09:10:21.038501+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-04T08:00:00+00:00 PythonOperator 2021-04-04T09:10:09.576118+00:00 2021-04-04T09:10:12.686232+00:00 0:00:03.110114 13433 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T09:10:07.058341+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-04T08:00:00+00:00 TriggerDagRunOperator 2021-04-04T09:09:59.537739+00:00 2021-04-04T09:10:00.156549+00:00 0:00:00.618810 13432 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T09:09:56.972171+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-04T08:00:00+00:00 TriggerDagRunOperator 2021-04-04T09:09:59.233914+00:00 2021-04-04T09:09:59.703864+00:00 0:00:00.469950 13431 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T09:09:56.972206+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-04T08:05:00+00:00 EmrJobFlowSensor 2021-04-04T09:06:06.993908+00:00 2021-04-04T09:15:09.635426+00:00 0:09:02.641518 13430 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T09:06:04.570384+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-04T08:05:00+00:00 EmrCreateJobFlowOperator 2021-04-04T09:05:44.672611+00:00 2021-04-04T09:05:46.338086+00:00 0:00:01.665475 13429 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T09:05:42.495380+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-04T08:05:00+00:00 PythonOperator 2021-04-04T09:05:14.652081+00:00 2021-04-04T09:05:17.369312+00:00 0:00:02.717231 13428 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T09:05:12.464734+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-04T08:00:00+00:00 EmrJobFlowSensor 2021-04-04T09:00:50.302082+00:00 2021-04-04T09:09:53.002715+00:00 0:09:02.700633 13427 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T09:00:48.098629+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-04T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T09:00:30.551481+00:00 2021-04-04T09:00:32.366464+00:00 0:00:01.814983 13426 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-04T09:00:28.162253+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-04T08:00:00+00:00 PythonOperator 2021-04-04T09:00:08.720953+00:00 2021-04-04T09:00:11.554998+00:00 0:00:02.834045 13425 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-04T09:00:06.063625+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-04T07:00:00+00:00 EmrJobFlowSensor 2021-04-04T08:12:58.173263+00:00 2021-04-04T08:22:00.750760+00:00 0:09:02.577497 13423 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T08:12:55.989546+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-04T07:00:00+00:00 EmrJobFlowSensor 2021-04-04T08:12:48.290107+00:00 2021-04-04T08:22:51.127747+00:00 0:10:02.837640 13422 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T08:12:45.979290+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-04T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T08:12:32.322853+00:00 2021-04-04T08:12:34.160077+00:00 0:00:01.837224 13421 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T08:12:29.974263+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-04T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T08:12:24.298316+00:00 2021-04-04T08:12:25.995172+00:00 0:00:01.696856 13420 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T08:12:21.904749+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-04T07:00:00+00:00 PythonOperator 2021-04-04T08:12:10.533122+00:00 2021-04-04T08:12:13.331913+00:00 0:00:02.798791 13419 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T08:12:07.889573+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-04T07:00:00+00:00 PythonOperator 2021-04-04T08:12:04.459425+00:00 2021-04-04T08:12:07.433715+00:00 0:00:02.974290 13418 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T08:12:01.892330+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-04T07:00:00+00:00 TriggerDagRunOperator 2021-04-04T08:11:58.551752+00:00 2021-04-04T08:11:59.081946+00:00 0:00:00.530194 13417 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T08:11:55.952871+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-04T07:00:00+00:00 TriggerDagRunOperator 2021-04-04T08:11:58.402615+00:00 2021-04-04T08:11:58.840140+00:00 0:00:00.437525 13416 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T08:11:55.952923+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-04T07:05:00+00:00 EmrJobFlowSensor 2021-04-04T08:06:01.855360+00:00 2021-04-04T08:15:04.467320+00:00 0:09:02.611960 13415 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T08:05:59.454683+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-04T07:05:00+00:00 EmrCreateJobFlowOperator 2021-04-04T08:05:41.639378+00:00 2021-04-04T08:05:43.382651+00:00 0:00:01.743273 13414 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T08:05:39.363025+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-04T07:05:00+00:00 PythonOperator 2021-04-04T08:05:19.726510+00:00 2021-04-04T08:05:22.406661+00:00 0:00:02.680151 13413 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T08:05:17.363088+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-04T07:00:00+00:00 EmrJobFlowSensor 2021-04-04T08:01:19.171818+00:00 2021-04-04T08:11:22.025393+00:00 0:10:02.853575 13412 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T08:01:16.871976+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-04T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T08:00:45.417665+00:00 2021-04-04T08:00:47.143018+00:00 0:00:01.725353 13411 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-04T08:00:42.824345+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-04T07:00:00+00:00 PythonOperator 2021-04-04T08:00:23.119192+00:00 2021-04-04T08:00:25.969827+00:00 0:00:02.850635 13410 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-04T08:00:20.807923+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-04T06:00:00+00:00 EmrJobFlowSensor 2021-04-04T07:13:27.737005+00:00 2021-04-04T07:23:30.573560+00:00 0:10:02.836555 13408 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T07:13:25.366021+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-04T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T07:13:05.576740+00:00 2021-04-04T07:13:07.261596+00:00 0:00:01.684856 13407 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T07:13:03.353234+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-04T06:00:00+00:00 PythonOperator 2021-04-04T07:12:45.621590+00:00 2021-04-04T07:12:48.576218+00:00 0:00:02.954628 13406 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T07:12:43.258842+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-04T06:00:00+00:00 EmrJobFlowSensor 2021-04-04T07:12:33.592533+00:00 2021-04-04T07:21:36.198519+00:00 0:09:02.605986 13405 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T07:12:31.258434+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-04T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T07:12:09.564820+00:00 2021-04-04T07:12:11.247640+00:00 0:00:01.682820 13404 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T07:12:07.220526+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-04T06:00:00+00:00 PythonOperator 2021-04-04T07:11:43.412244+00:00 2021-04-04T07:11:46.148143+00:00 0:00:02.735899 13403 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T07:11:41.208691+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-04T06:00:00+00:00 TriggerDagRunOperator 2021-04-04T07:11:29.693685+00:00 2021-04-04T07:11:30.234429+00:00 0:00:00.540744 13402 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T07:11:27.189891+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-04T06:00:00+00:00 TriggerDagRunOperator 2021-04-04T07:11:29.573303+00:00 2021-04-04T07:11:29.978133+00:00 0:00:00.404830 13401 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T07:11:27.189853+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-04T06:05:00+00:00 EmrJobFlowSensor 2021-04-04T07:06:06.815384+00:00 2021-04-04T07:15:09.422933+00:00 0:09:02.607549 13400 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T07:06:04.491021+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-04T06:05:00+00:00 EmrCreateJobFlowOperator 2021-04-04T07:05:45.069811+00:00 2021-04-04T07:05:46.721475+00:00 0:00:01.651664 13399 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T07:05:42.552946+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-04T06:05:00+00:00 PythonOperator 2021-04-04T07:05:24.744869+00:00 2021-04-04T07:05:27.547237+00:00 0:00:02.802368 13398 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T07:05:22.457463+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-04T06:00:00+00:00 EmrJobFlowSensor 2021-04-04T07:01:04.353311+00:00 2021-04-04T07:11:07.196185+00:00 0:10:02.842874 13397 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T07:01:01.866757+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-04T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T07:00:42.144008+00:00 2021-04-04T07:00:43.997189+00:00 0:00:01.853181 13396 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-04T07:00:39.850199+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-04T06:00:00+00:00 PythonOperator 2021-04-04T07:00:20.080810+00:00 2021-04-04T07:00:22.803712+00:00 0:00:02.722902 13395 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-04T07:00:17.691064+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-04T05:00:00+00:00 EmrJobFlowSensor 2021-04-04T06:11:25.420345+00:00 2021-04-04T06:20:28.071642+00:00 0:09:02.651297 13393 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T06:11:23.194591+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-04T05:00:00+00:00 EmrJobFlowSensor 2021-04-04T06:11:15.632502+00:00 2021-04-04T06:21:18.370326+00:00 0:10:02.737824 13392 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T06:11:13.262580+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-04T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T06:11:03.487500+00:00 2021-04-04T06:11:05.445760+00:00 0:00:01.958260 13391 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T06:11:01.084799+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-04T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T06:10:55.502466+00:00 2021-04-04T06:10:57.299047+00:00 0:00:01.796581 13390 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T06:10:53.087826+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-04T05:00:00+00:00 PythonOperator 2021-04-04T06:10:41.217894+00:00 2021-04-04T06:10:44.068449+00:00 0:00:02.850555 13389 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T06:10:39.017183+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-04T05:00:00+00:00 PythonOperator 2021-04-04T06:10:33.300375+00:00 2021-04-04T06:10:36.264366+00:00 0:00:02.963991 13388 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T06:10:31.011235+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-04T05:00:00+00:00 TriggerDagRunOperator 2021-04-04T06:10:25.462073+00:00 2021-04-04T06:10:26.014591+00:00 0:00:00.552518 13387 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T06:10:23.006710+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-04T05:00:00+00:00 TriggerDagRunOperator 2021-04-04T06:10:25.349939+00:00 2021-04-04T06:10:25.815898+00:00 0:00:00.465959 13386 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T06:10:23.006672+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-04T05:05:00+00:00 EmrJobFlowSensor 2021-04-04T06:05:50.683530+00:00 2021-04-04T06:14:53.249916+00:00 0:09:02.566386 13385 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T06:05:48.510206+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-04T05:05:00+00:00 EmrCreateJobFlowOperator 2021-04-04T06:05:28.858783+00:00 2021-04-04T06:05:30.604908+00:00 0:00:01.746125 13384 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T06:05:26.472876+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-04T05:05:00+00:00 PythonOperator 2021-04-04T06:05:06.785680+00:00 2021-04-04T06:05:09.506995+00:00 0:00:02.721315 13383 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T06:05:04.446862+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-04T05:00:00+00:00 EmrJobFlowSensor 2021-04-04T06:01:04.668682+00:00 2021-04-04T06:10:07.438137+00:00 0:09:02.769455 13382 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T06:01:02.055853+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-04T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T06:00:42.329187+00:00 2021-04-04T06:00:44.039118+00:00 0:00:01.709931 13381 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-04T06:00:39.996827+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-04T05:00:00+00:00 PythonOperator 2021-04-04T06:00:20.303693+00:00 2021-04-04T06:00:23.016879+00:00 0:00:02.713186 13380 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-04T06:00:17.969704+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-04T04:00:00+00:00 EmrJobFlowSensor 2021-04-04T05:12:36.305146+00:00 2021-04-04T05:22:39.087470+00:00 0:10:02.782324 13378 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T05:12:34.121883+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-04T04:00:00+00:00 EmrJobFlowSensor 2021-04-04T05:12:24.410182+00:00 2021-04-04T05:22:27.221137+00:00 0:10:02.810955 13377 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T05:12:22.119385+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-04T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T05:12:14.596335+00:00 2021-04-04T05:12:16.368071+00:00 0:00:01.771736 13376 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T05:12:12.105609+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-04T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T05:12:04.572694+00:00 2021-04-04T05:12:06.333176+00:00 0:00:01.760482 13375 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T05:12:02.096563+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-04T04:00:00+00:00 PythonOperator 2021-04-04T05:11:54.755105+00:00 2021-04-04T05:11:57.535896+00:00 0:00:02.780791 13374 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T05:11:52.088088+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-04T04:00:00+00:00 PythonOperator 2021-04-04T05:11:42.599523+00:00 2021-04-04T05:11:45.570911+00:00 0:00:02.971388 13373 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T05:11:40.071403+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-04T04:00:00+00:00 TriggerDagRunOperator 2021-04-04T05:11:30.872977+00:00 2021-04-04T05:11:31.383188+00:00 0:00:00.510211 13372 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T05:11:28.241121+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-04T04:00:00+00:00 TriggerDagRunOperator 2021-04-04T05:11:30.807664+00:00 2021-04-04T05:11:31.231563+00:00 0:00:00.423899 13371 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T05:11:28.241064+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-04T04:05:00+00:00 EmrJobFlowSensor 2021-04-04T05:06:07.757521+00:00 2021-04-04T05:15:10.334038+00:00 0:09:02.576517 13370 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T05:06:05.551897+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-04T04:05:00+00:00 EmrCreateJobFlowOperator 2021-04-04T05:05:45.873297+00:00 2021-04-04T05:05:47.651496+00:00 0:00:01.778199 13369 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T05:05:43.384012+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-04T04:05:00+00:00 PythonOperator 2021-04-04T05:05:25.654300+00:00 2021-04-04T05:05:28.333176+00:00 0:00:02.678876 13368 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T05:05:23.368669+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-04T04:00:00+00:00 EmrJobFlowSensor 2021-04-04T05:01:03.165430+00:00 2021-04-04T05:11:06.061450+00:00 0:10:02.896020 13367 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T05:01:00.841327+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-04T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T05:00:43.073002+00:00 2021-04-04T05:00:44.923730+00:00 0:00:01.850728 13366 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-04T05:00:40.823300+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-04T04:00:00+00:00 PythonOperator 2021-04-04T05:00:21.146359+00:00 2021-04-04T05:00:24.037451+00:00 0:00:02.891092 13365 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-04T05:00:18.802072+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-04T03:00:00+00:00 EmrJobFlowSensor 2021-04-04T04:12:45.259448+00:00 2021-04-04T04:22:48.099187+00:00 0:10:02.839739 13363 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T04:12:42.770347+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-04T03:00:00+00:00 EmrJobFlowSensor 2021-04-04T04:12:33.284335+00:00 2021-04-04T04:21:35.955240+00:00 0:09:02.670905 13362 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T04:12:30.757696+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-04T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T04:12:24.925881+00:00 2021-04-04T04:12:26.600729+00:00 0:00:01.674848 13361 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T04:12:22.704271+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-04T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T04:12:10.921882+00:00 2021-04-04T04:12:12.748872+00:00 0:00:01.826990 13360 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T04:12:08.693538+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-04T03:00:00+00:00 PythonOperator 2021-04-04T04:12:02.942563+00:00 2021-04-04T04:12:05.680237+00:00 0:00:02.737674 13359 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T04:12:00.683916+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-04T03:00:00+00:00 PythonOperator 2021-04-04T04:11:48.916673+00:00 2021-04-04T04:11:51.941427+00:00 0:00:03.024754 13358 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T04:11:46.626412+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-04T03:00:00+00:00 TriggerDagRunOperator 2021-04-04T04:11:42.931230+00:00 2021-04-04T04:11:43.340714+00:00 0:00:00.409484 13357 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T04:11:40.623316+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-04T03:00:00+00:00 TriggerDagRunOperator 2021-04-04T04:11:42.959065+00:00 2021-04-04T04:11:43.497781+00:00 0:00:00.538716 13356 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T04:11:40.623282+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-04T03:05:00+00:00 EmrJobFlowSensor 2021-04-04T04:05:54.428914+00:00 2021-04-04T04:14:56.960513+00:00 0:09:02.531599 13355 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T04:05:52.226043+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-04T03:05:00+00:00 EmrCreateJobFlowOperator 2021-04-04T04:05:34.408639+00:00 2021-04-04T04:05:36.039012+00:00 0:00:01.630373 13354 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T04:05:32.213488+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-04T03:05:00+00:00 PythonOperator 2021-04-04T04:05:10.570984+00:00 2021-04-04T04:05:13.239931+00:00 0:00:02.668947 13353 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T04:05:08.258451+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-04T03:00:00+00:00 EmrJobFlowSensor 2021-04-04T04:01:17.908812+00:00 2021-04-04T04:11:20.619843+00:00 0:10:02.711031 13352 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T04:01:15.775338+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-04T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T04:00:56.088043+00:00 2021-04-04T04:00:57.792283+00:00 0:00:01.704240 13351 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-04T04:00:53.756544+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-04T03:00:00+00:00 PythonOperator 2021-04-04T04:00:26.331926+00:00 2021-04-04T04:00:29.035471+00:00 0:00:02.703545 13350 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-04T04:00:23.749637+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-04T02:00:00+00:00 EmrJobFlowSensor 2021-04-04T03:11:25.088879+00:00 2021-04-04T03:21:27.835485+00:00 0:10:02.746606 13348 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T03:11:22.561810+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-04T02:00:00+00:00 EmrJobFlowSensor 2021-04-04T03:11:18.998463+00:00 2021-04-04T03:20:21.531622+00:00 0:09:02.533159 13347 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T03:11:16.476441+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-04T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T03:11:04.653386+00:00 2021-04-04T03:11:06.420585+00:00 0:00:01.767199 13346 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T03:11:02.422028+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-04T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T03:10:58.618334+00:00 2021-04-04T03:11:00.324626+00:00 0:00:01.706292 13345 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T03:10:56.424802+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-04T02:00:00+00:00 PythonOperator 2021-04-04T03:10:42.553451+00:00 2021-04-04T03:10:45.239951+00:00 0:00:02.686500 13344 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T03:10:40.400762+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-04T02:00:00+00:00 PythonOperator 2021-04-04T03:10:36.699926+00:00 2021-04-04T03:10:39.779814+00:00 0:00:03.079888 13343 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T03:10:34.397547+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-04T02:00:00+00:00 TriggerDagRunOperator 2021-04-04T03:10:19.403455+00:00 2021-04-04T03:10:19.930764+00:00 0:00:00.527309 13342 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T03:10:16.389347+00:00 2 default_pool