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 vc-asset-import_v002 check_cluster_status 2021-05-11T03:05:00+00:00 EmrJobFlowSensor 2021-05-11T04:06:14.191426+00:00 2021-05-11T04:14:16.788342+00:00 0:08:02.596916 26782 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T04:06:11.896427+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-11T03:05:00+00:00 EmrCreateJobFlowOperator 2021-05-11T04:05:43.978120+00:00 2021-05-11T04:05:45.633427+00:00 0:00:01.655307 26781 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-11T04:05:41.847085+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-11T03:05:00+00:00 PythonOperator 2021-05-11T04:05:20.082345+00:00 2021-05-11T04:05:23.092349+00:00 0:00:03.010004 26780 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T04:05:17.825263+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-11T03:00:00+00:00 EmrJobFlowSensor 2021-05-11T04:00:57.524549+00:00 2021-05-11T04:11:00.365445+00:00 0:10:02.840896 26779 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T04:00:55.402813+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-11T03:00:00+00:00 EmrCreateJobFlowOperator 2021-05-11T04:00:35.510867+00:00 2021-05-11T04:00:37.232014+00:00 0:00:01.721147 26778 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-11T04:00:33.390747+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-11T03:00:00+00:00 PythonOperator 2021-05-11T04:00:16.040345+00:00 2021-05-11T04:00:19.145663+00:00 0:00:03.105318 26777 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-11T04:00:13.119946+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-11T02:00:00+00:00 EmrJobFlowSensor 2021-05-11T03:11:19.899098+00:00 2021-05-11T03:20:22.555918+00:00 0:09:02.656820 26775 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T03:11:17.690455+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-11T02:00:00+00:00 EmrJobFlowSensor 2021-05-11T03:11:13.911994+00:00 2021-05-11T03:20:16.673308+00:00 0:09:02.761314 26774 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T03:11:11.650153+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-11T02:00:00+00:00 EmrCreateJobFlowOperator 2021-05-11T03:10:57.854673+00:00 2021-05-11T03:10:59.497109+00:00 0:00:01.642436 26773 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-11T03:10:55.667554+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-11T02:00:00+00:00 EmrCreateJobFlowOperator 2021-05-11T03:10:52.046428+00:00 2021-05-11T03:10:53.947738+00:00 0:00:01.901310 26772 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-11T03:10:49.680891+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-11T02:00:00+00:00 PythonOperator 2021-05-11T03:10:36.210326+00:00 2021-05-11T03:10:39.611409+00:00 0:00:03.401083 26771 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T03:10:33.672565+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-11T02:00:00+00:00 PythonOperator 2021-05-11T03:10:29.968969+00:00 2021-05-11T03:10:33.133745+00:00 0:00:03.164776 26770 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T03:10:27.744242+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-11T02:00:00+00:00 TriggerDagRunOperator 2021-05-11T03:10:11.824139+00:00 2021-05-11T03:10:12.344092+00:00 0:00:00.519953 26769 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T03:10:09.584483+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-11T02:00:00+00:00 TriggerDagRunOperator 2021-05-11T03:10:11.684333+00:00 2021-05-11T03:10:12.092801+00:00 0:00:00.408468 26768 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T03:10:09.584515+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-11T02:05:00+00:00 EmrJobFlowSensor 2021-05-11T03:05:49.245079+00:00 2021-05-11T03:14:51.785921+00:00 0:09:02.540842 26767 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T03:05:47.139611+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-11T02:05:00+00:00 EmrCreateJobFlowOperator 2021-05-11T03:05:27.488152+00:00 2021-05-11T03:05:29.143876+00:00 0:00:01.655724 26766 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-11T03:05:25.240873+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-11T02:05:00+00:00 PythonOperator 2021-05-11T03:05:05.727386+00:00 2021-05-11T03:05:09.020912+00:00 0:00:03.293526 26765 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T03:05:03.152619+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-11T02:00:00+00:00 EmrJobFlowSensor 2021-05-11T03:00:48.798048+00:00 2021-05-11T03:09:51.457360+00:00 0:09:02.659312 26764 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T03:00:46.643916+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-11T02:00:00+00:00 EmrCreateJobFlowOperator 2021-05-11T03:00:29.055075+00:00 2021-05-11T03:00:30.870110+00:00 0:00:01.815035 26763 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-11T03:00:26.549163+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-11T02:00:00+00:00 PythonOperator 2021-05-11T03:00:06.800546+00:00 2021-05-11T03:00:09.947753+00:00 0:00:03.147207 26762 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-11T03:00:04.433644+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-11T01:00:00+00:00 EmrJobFlowSensor 2021-05-11T02:10:20.111671+00:00 2021-05-11T02:19:22.924389+00:00 0:09:02.812718 26760 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T02:10:17.665694+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-11T01:00:00+00:00 EmrJobFlowSensor 2021-05-11T02:10:08.228980+00:00 2021-05-11T02:21:11.420086+00:00 0:11:03.191106 26759 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T02:10:05.600343+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-11T01:00:00+00:00 EmrCreateJobFlowOperator 2021-05-11T02:10:00.287734+00:00 2021-05-11T02:10:02.114267+00:00 0:00:01.826533 26758 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-11T02:09:57.749441+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-11T01:00:00+00:00 EmrCreateJobFlowOperator 2021-05-11T02:09:46.254830+00:00 2021-05-11T02:09:47.928652+00:00 0:00:01.673822 26757 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-11T02:09:43.568592+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-11T01:00:00+00:00 PythonOperator 2021-05-11T02:09:37.672055+00:00 2021-05-11T02:09:40.807032+00:00 0:00:03.134977 26756 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T02:09:35.556874+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-11T01:00:00+00:00 PythonOperator 2021-05-11T02:09:24.066341+00:00 2021-05-11T02:09:27.436832+00:00 0:00:03.370491 26755 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T02:09:21.567134+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-11T01:00:00+00:00 TriggerDagRunOperator 2021-05-11T02:09:14.108562+00:00 2021-05-11T02:09:14.655140+00:00 0:00:00.546578 26754 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T02:09:11.555598+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-11T01:00:00+00:00 TriggerDagRunOperator 2021-05-11T02:09:13.938915+00:00 2021-05-11T02:09:14.441630+00:00 0:00:00.502715 26753 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T02:09:11.555629+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-11T01:05:00+00:00 EmrJobFlowSensor 2021-05-11T02:05:55.542136+00:00 2021-05-11T02:13:58.114364+00:00 0:08:02.572228 26752 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T02:05:53.169115+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-11T01:05:00+00:00 EmrCreateJobFlowOperator 2021-05-11T02:05:33.389882+00:00 2021-05-11T02:05:35.047382+00:00 0:00:01.657500 26751 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-11T02:05:31.150847+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-11T01:05:00+00:00 PythonOperator 2021-05-11T02:05:11.167867+00:00 2021-05-11T02:05:14.314896+00:00 0:00:03.147029 26750 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T02:05:09.037851+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-11T01:00:00+00:00 EmrJobFlowSensor 2021-05-11T02:00:54.662864+00:00 2021-05-11T02:08:57.237411+00:00 0:08:02.574547 26749 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T02:00:52.462608+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-11T01:00:00+00:00 EmrCreateJobFlowOperator 2021-05-11T02:00:30.692537+00:00 2021-05-11T02:00:32.397442+00:00 0:00:01.704905 26748 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-11T02:00:28.463133+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-11T01:00:00+00:00 PythonOperator 2021-05-11T02:00:05.301265+00:00 2021-05-11T02:00:08.513170+00:00 0:00:03.211905 26747 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-11T02:00:02.469390+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-11T00:00:00+00:00 EmrJobFlowSensor 2021-05-11T01:10:47.904167+00:00 2021-05-11T01:20:50.631849+00:00 0:10:02.727682 26745 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T01:10:45.747689+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-11T00:00:00+00:00 EmrJobFlowSensor 2021-05-11T01:10:45.997135+00:00 2021-05-11T01:19:48.734768+00:00 0:09:02.737633 26744 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T01:10:43.752888+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-11T00:00:00+00:00 EmrCreateJobFlowOperator 2021-05-11T01:10:27.913545+00:00 2021-05-11T01:10:29.653665+00:00 0:00:01.740120 26743 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-11T01:10:25.738693+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-11T00:00:00+00:00 EmrCreateJobFlowOperator 2021-05-11T01:10:24.118676+00:00 2021-05-11T01:10:25.815130+00:00 0:00:01.696454 26742 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-11T01:10:21.728527+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-11T00:00:00+00:00 PythonOperator 2021-05-11T01:10:06.660478+00:00 2021-05-11T01:10:09.998447+00:00 0:00:03.337969 26741 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T01:10:03.712174+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-11T00:00:00+00:00 PythonOperator 2021-05-11T01:10:03.976979+00:00 2021-05-11T01:10:07.025455+00:00 0:00:03.048476 26740 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T01:10:01.707927+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-11T00:00:00+00:00 TriggerDagRunOperator 2021-05-11T01:09:58.802600+00:00 2021-05-11T01:09:59.313034+00:00 0:00:00.510434 26739 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T01:09:55.707638+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-11T00:00:00+00:00 TriggerDagRunOperator 2021-05-11T01:09:58.071919+00:00 2021-05-11T01:09:58.463924+00:00 0:00:00.392005 26738 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T01:09:55.707588+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-11T00:05:00+00:00 EmrJobFlowSensor 2021-05-11T01:05:53.768368+00:00 2021-05-11T01:14:56.497215+00:00 0:09:02.728847 26737 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T01:05:51.326645+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-11T00:05:00+00:00 EmrCreateJobFlowOperator 2021-05-11T01:05:31.660269+00:00 2021-05-11T01:05:33.479761+00:00 0:00:01.819492 26736 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-11T01:05:29.377722+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-11T00:05:00+00:00 PythonOperator 2021-05-11T01:05:09.429929+00:00 2021-05-11T01:05:12.551664+00:00 0:00:03.121735 26735 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T01:05:07.293030+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-11T00:00:00+00:00 EmrJobFlowSensor 2021-05-11T01:00:47.275756+00:00 2021-05-11T01:09:50.120591+00:00 0:09:02.844835 26734 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T01:00:44.971222+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-11T00:00:00+00:00 EmrCreateJobFlowOperator 2021-05-11T01:00:25.435055+00:00 2021-05-11T01:00:27.286610+00:00 0:00:01.851555 26733 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-11T01:00:22.955821+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-11T00:00:00+00:00 PythonOperator 2021-05-11T01:00:03.646013+00:00 2021-05-11T01:00:06.829958+00:00 0:00:03.183945 26732 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-11T01:00:00.963017+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-10T23:00:00+00:00 EmrJobFlowSensor 2021-05-11T00:11:41.017408+00:00 2021-05-11T00:21:43.848036+00:00 0:10:02.830628 26730 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T00:11:38.891968+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-10T23:00:00+00:00 EmrJobFlowSensor 2021-05-11T00:11:33.293506+00:00 2021-05-11T00:21:36.403084+00:00 0:10:03.109578 26729 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T00:11:30.883641+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-10T23:00:00+00:00 EmrCreateJobFlowOperator 2021-05-11T00:11:19.625637+00:00 2021-05-11T00:11:21.306237+00:00 0:00:01.680600 26728 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-11T00:11:17.059865+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-10T23:00:00+00:00 EmrCreateJobFlowOperator 2021-05-11T00:11:11.131289+00:00 2021-05-11T00:11:12.913966+00:00 0:00:01.782677 26727 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-11T00:11:08.793479+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-10T23:00:00+00:00 PythonOperator 2021-05-11T00:10:57.081043+00:00 2021-05-11T00:11:00.178727+00:00 0:00:03.097684 26726 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T00:10:54.854979+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-10T23:00:00+00:00 PythonOperator 2021-05-11T00:10:49.294643+00:00 2021-05-11T00:10:52.675492+00:00 0:00:03.380849 26725 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T00:10:46.861879+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-10T23:00:00+00:00 TriggerDagRunOperator 2021-05-11T00:10:33.409576+00:00 2021-05-11T00:10:33.952601+00:00 0:00:00.543025 26724 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T00:10:30.764111+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-10T23:00:00+00:00 TriggerDagRunOperator 2021-05-11T00:10:33.300601+00:00 2021-05-11T00:10:33.696299+00:00 0:00:00.395698 26723 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T00:10:30.764061+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-10T23:05:00+00:00 EmrJobFlowSensor 2021-05-11T00:05:58.497840+00:00 2021-05-11T00:14:01.087707+00:00 0:08:02.589867 26722 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T00:05:56.010701+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-10T23:05:00+00:00 EmrCreateJobFlowOperator 2021-05-11T00:05:38.166397+00:00 2021-05-11T00:05:39.915604+00:00 0:00:01.749207 26721 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-11T00:05:35.992539+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-10T23:05:00+00:00 PythonOperator 2021-05-11T00:05:16.076042+00:00 2021-05-11T00:05:19.120818+00:00 0:00:03.044776 26720 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T00:05:13.968945+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-10T23:00:00+00:00 EmrJobFlowSensor 2021-05-11T00:01:09.581386+00:00 2021-05-11T00:10:12.340172+00:00 0:09:02.758786 26719 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T00:01:07.470134+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-10T23:00:00+00:00 EmrCreateJobFlowOperator 2021-05-11T00:00:39.654440+00:00 2021-05-11T00:00:41.374295+00:00 0:00:01.719855 26718 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-11T00:00:37.409701+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-10T23:00:00+00:00 PythonOperator 2021-05-11T00:00:17.603087+00:00 2021-05-11T00:00:20.711950+00:00 0:00:03.108863 26717 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-11T00:00:15.389457+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-10T22:00:00+00:00 EmrJobFlowSensor 2021-05-10T23:12:59.007345+00:00 2021-05-10T23:29:02.700235+00:00 0:16:03.692890 26716 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T23:12:56.362356+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-10T22:00:00+00:00 EmrJobFlowSensor 2021-05-10T23:12:58.668493+00:00 2021-05-10T23:21:01.190344+00:00 0:08:02.521851 26715 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T23:12:56.362325+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-10T22:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T23:12:36.885163+00:00 2021-05-10T23:12:38.690751+00:00 0:00:01.805588 26714 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-10T23:12:34.353814+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-10T22:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T23:12:36.710214+00:00 2021-05-10T23:12:38.408300+00:00 0:00:01.698086 26713 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-10T23:12:34.353859+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-10T22:00:00+00:00 PythonOperator 2021-05-10T23:12:16.547690+00:00 2021-05-10T23:12:19.636698+00:00 0:00:03.089008 26712 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T23:12:14.265918+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-10T22:00:00+00:00 PythonOperator 2021-05-10T23:12:16.422842+00:00 2021-05-10T23:12:19.687115+00:00 0:00:03.264273 26711 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T23:12:14.265888+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-10T22:00:00+00:00 TriggerDagRunOperator 2021-05-10T23:11:56.935152+00:00 2021-05-10T23:11:57.472450+00:00 0:00:00.537298 26710 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T23:11:54.251242+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-10T22:00:00+00:00 TriggerDagRunOperator 2021-05-10T23:11:56.799982+00:00 2021-05-10T23:11:57.257740+00:00 0:00:00.457758 26709 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T23:11:54.251283+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-10T22:05:00+00:00 EmrJobFlowSensor 2021-05-10T23:05:47.186815+00:00 2021-05-10T23:14:49.760467+00:00 0:09:02.573652 26707 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T23:05:44.945589+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-10T22:05:00+00:00 EmrCreateJobFlowOperator 2021-05-10T23:05:25.076018+00:00 2021-05-10T23:05:26.724495+00:00 0:00:01.648477 26706 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-10T23:05:22.860260+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-10T22:05:00+00:00 PythonOperator 2021-05-10T23:05:04.952976+00:00 2021-05-10T23:05:08.007052+00:00 0:00:03.054076 26705 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T23:05:02.797489+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-10T22:00:00+00:00 EmrJobFlowSensor 2021-05-10T23:01:08.716064+00:00 2021-05-10T23:10:11.680824+00:00 0:09:02.964760 26704 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T23:01:06.431006+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2021-05-09T23:00:00+00:00 EmrJobFlowSensor 2021-05-10T23:01:06.449165+00:00 2021-05-10T23:11:09.236606+00:00 0:10:02.787441 26703 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T23:01:04.427502+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-10T22:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T23:00:44.652409+00:00 2021-05-10T23:00:46.428766+00:00 0:00:01.776357 26702 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-10T23:00:42.385345+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2021-05-09T23:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T23:00:42.585510+00:00 2021-05-10T23:00:44.347207+00:00 0:00:01.761697 26701 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-10T23:00:40.384087+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2021-05-09T23:00:00+00:00 PythonOperator 2021-05-10T23:00:20.667460+00:00 2021-05-10T23:00:23.821757+00:00 0:00:03.154297 26700 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T23:00:18.374433+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-10T22:00:00+00:00 PythonOperator 2021-05-10T23:00:14.533316+00:00 2021-05-10T23:00:17.656180+00:00 0:00:03.122864 26699 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-10T23:00:12.360063+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-10T21:00:00+00:00 EmrJobFlowSensor 2021-05-10T22:10:14.067436+00:00 2021-05-10T22:21:16.943144+00:00 0:11:02.875708 26698 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T22:10:11.745580+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-10T21:00:00+00:00 EmrJobFlowSensor 2021-05-10T22:10:11.888686+00:00 2021-05-10T22:19:14.769760+00:00 0:09:02.881074 26697 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T22:10:09.739917+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-10T21:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T22:09:54.010985+00:00 2021-05-10T22:09:55.757230+00:00 0:00:01.746245 26696 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-10T22:09:51.727912+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-10T21:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T22:09:50.143373+00:00 2021-05-10T22:09:51.982051+00:00 0:00:01.838678 26695 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-10T22:09:47.724588+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-10T21:00:00+00:00 PythonOperator 2021-05-10T22:09:30.410151+00:00 2021-05-10T22:09:33.682936+00:00 0:00:03.272785 26694 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T22:09:27.769348+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-10T21:00:00+00:00 PythonOperator 2021-05-10T22:09:28.000567+00:00 2021-05-10T22:09:31.478529+00:00 0:00:03.477962 26693 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T22:09:25.773970+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-10T21:00:00+00:00 TriggerDagRunOperator 2021-05-10T22:09:08.302579+00:00 2021-05-10T22:09:08.848808+00:00 0:00:00.546229 26692 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T22:09:05.694361+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-10T21:00:00+00:00 TriggerDagRunOperator 2021-05-10T22:09:08.253539+00:00 2021-05-10T22:09:08.663356+00:00 0:00:00.409817 26691 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T22:09:05.694401+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-10T21:05:00+00:00 EmrJobFlowSensor 2021-05-10T22:06:10.050878+00:00 2021-05-10T22:15:12.668064+00:00 0:09:02.617186 26689 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T22:06:07.913113+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-10T21:05:00+00:00 EmrCreateJobFlowOperator 2021-05-10T22:05:42.230308+00:00 2021-05-10T22:05:44.084643+00:00 0:00:01.854335 26688 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-10T22:05:39.948298+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-10T21:05:00+00:00 PythonOperator 2021-05-10T22:05:22.307419+00:00 2021-05-10T22:05:25.440669+00:00 0:00:03.133250 26687 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T22:05:19.830940+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-10T21:00:00+00:00 EmrJobFlowSensor 2021-05-10T22:00:47.675474+00:00 2021-05-10T22:08:50.295930+00:00 0:08:02.620456 26686 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T22:00:45.320731+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-10T21:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T22:00:25.838668+00:00 2021-05-10T22:00:27.746770+00:00 0:00:01.908102 26685 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-10T22:00:23.369612+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-10T21:00:00+00:00 PythonOperator 2021-05-10T22:00:05.526383+00:00 2021-05-10T22:00:08.610571+00:00 0:00:03.084188 26684 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-10T22:00:03.288917+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-10T20:00:00+00:00 EmrJobFlowSensor 2021-05-10T21:11:12.260526+00:00 2021-05-10T21:20:15.089291+00:00 0:09:02.828765 26683 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T21:11:10.034964+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-10T20:00:00+00:00 EmrJobFlowSensor 2021-05-10T21:11:00.343777+00:00 2021-05-10T21:19:03.068463+00:00 0:08:02.724686 26682 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T21:10:58.023642+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-10T20:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T21:10:50.431007+00:00 2021-05-10T21:10:52.148511+00:00 0:00:01.717504 26681 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-10T21:10:48.013849+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-10T20:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T21:10:38.392832+00:00 2021-05-10T21:10:40.060222+00:00 0:00:01.667390 26680 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-10T21:10:36.052869+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-10T20:00:00+00:00 PythonOperator 2021-05-10T21:10:28.474725+00:00 2021-05-10T21:10:31.791238+00:00 0:00:03.316513 26679 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T21:10:26.060560+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-10T20:00:00+00:00 PythonOperator 2021-05-10T21:10:16.734117+00:00 2021-05-10T21:10:19.947148+00:00 0:00:03.213031 26678 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T21:10:14.061311+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-10T20:00:00+00:00 TriggerDagRunOperator 2021-05-10T21:10:08.869518+00:00 2021-05-10T21:10:09.318670+00:00 0:00:00.449152 26677 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T21:10:05.855197+00:00 2 default_pool