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

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

Task Instances

  State Dag Id Task Id Execution Date Operator Start Date End Date Duration Job Id Hostname Unixname Priority Weight Queue Queued Dttm Try Number Pool Log Url
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-31T09:00:00+00:00 TriggerDagRunOperator 2021-03-31T10:20:51.838228+00:00 2021-03-31T10:20:52.254437+00:00 0:00:00.416209 12009 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T10:20:49.624082+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-31T09:57:52.043506+00:00 PythonOperator 2021-03-31T10:11:49.135945+00:00 2021-03-31T10:11:51.831671+00:00 0:00:02.695726 12008 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-31T10:11:46.950012+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-31T08:00:00+00:00 EmrCreateJobFlowOperator 2021-03-31T10:11:24.330664+00:00 2021-03-31T10:11:26.241155+00:00 0:00:01.910491 12007 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-31T08:00:00+00:00 EmrJobFlowSensor 2021-03-31T10:11:18.289008+00:00 2021-03-31T10:23:21.397776+00:00 0:12:03.108768 12006 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-31T08:00:00+00:00 PythonOperator 2021-03-31T10:11:06.213244+00:00 2021-03-31T10:11:08.965152+00:00 0:00:02.751908 12005 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-31T08:00:00+00:00 EmrCreateJobFlowOperator 2021-03-31T10:10:39.113272+00:00 2021-03-31T10:10:40.788523+00:00 0:00:01.675251 12004 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-31T08:00:00+00:00 PythonOperator 2021-03-31T10:10:27.161530+00:00 2021-03-31T10:10:30.106224+00:00 0:00:02.944694 12003 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-31T09:05:00+00:00 EmrJobFlowSensor 2021-03-31T10:05:54.725111+00:00 2021-03-31T10:14:57.461473+00:00 0:09:02.736362 12002 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T10:05:52.484329+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-31T09:05:00+00:00 EmrCreateJobFlowOperator 2021-03-31T10:05:24.772003+00:00 2021-03-31T10:05:26.436066+00:00 0:00:01.664063 12001 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-31T10:05:22.467695+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-31T09:05:00+00:00 PythonOperator 2021-03-31T10:05:04.570770+00:00 2021-03-31T10:05:07.233564+00:00 0:00:02.662794 12000 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-31T10:05:02.313218+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-31T09:00:00+00:00 EmrJobFlowSensor 2021-03-31T10:03:24.546714+00:00 2021-03-31T10:20:28.333125+00:00 0:17:03.786411 11999 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-31T10:03:22.181849+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-31T09:00:00+00:00 EmrCreateJobFlowOperator 2021-03-31T10:03:02.014425+00:00 2021-03-31T10:03:03.761016+00:00 0:00:01.746591 11998 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-31T10:02:59.668484+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-31T08:00:00+00:00 TriggerDagRunOperator 2021-03-31T10:02:45.211696+00:00 2021-03-31T10:02:45.811230+00:00 0:00:00.599534 11997 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T10:02:39.237017+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-31T09:00:00+00:00 PythonOperator 2021-03-31T10:02:45.133523+00:00 2021-03-31T10:02:48.134475+00:00 0:00:03.000952 11996 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-31T10:02:39.237067+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-31T08:00:00+00:00 TriggerDagRunOperator 2021-03-31T10:02:42.721036+00:00 2021-03-31T10:02:43.457481+00:00 0:00:00.736445 11994 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T10:02:39.237053+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-31T08:00:00+00:00 EmrJobFlowSensor 2021-03-31T09:48:08.964739+00:00 2021-03-31T09:57:11.644518+00:00 0:09:02.679779 11992 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-31T09:48:06.601311+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-31T08:05:00+00:00 EmrJobFlowSensor 2021-03-31T09:47:54.989151+00:00 2021-03-31T09:55:57.549436+00:00 0:08:02.560285 11991 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T09:47:52.604824+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-31T08:00:00+00:00 EmrCreateJobFlowOperator 2021-03-31T09:47:47.318217+00:00 2021-03-31T09:47:49.016649+00:00 0:00:01.698432 11990 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-31T09:47:44.594152+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-31T08:05:00+00:00 EmrCreateJobFlowOperator 2021-03-31T09:47:35.002352+00:00 2021-03-31T09:47:36.639044+00:00 0:00:01.636692 11989 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-31T09:47:32.656312+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-31T08:00:00+00:00 PythonOperator 2021-03-31T09:47:25.240601+00:00 2021-03-31T09:47:28.075930+00:00 0:00:02.835329 11988 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-31T09:47:22.859483+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-31T08:05:00+00:00 PythonOperator 2021-03-31T09:47:11.153606+00:00 2021-03-31T09:47:13.953364+00:00 0:00:02.799758 11987 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-31T09:47:08.557974+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-26T12:00:00+00:00 EmrJobFlowSensor 2021-03-26T13:21:10.412036+00:00 2021-03-26T13:33:13.489038+00:00 0:12:03.077002 11877 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-26T13:21:08.190970+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-26T12:00:00+00:00 EmrCreateJobFlowOperator 2021-03-26T13:20:46.441933+00:00 2021-03-26T13:20:48.243338+00:00 0:00:01.801405 11876 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-26T13:20:44.159748+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-26T12:00:00+00:00 PythonOperator 2021-03-26T13:20:24.662631+00:00 2021-03-26T13:20:27.619554+00:00 0:00:02.956923 11875 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-26T13:20:22.026970+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-26T12:00:00+00:00 TriggerDagRunOperator 2021-03-26T13:20:12.933503+00:00 2021-03-26T13:20:13.321428+00:00 0:00:00.387925 11874 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-26T13:20:10.068374+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-26T12:00:00+00:00 TriggerDagRunOperator 2021-03-26T13:20:12.760958+00:00 2021-03-26T13:20:13.274374+00:00 0:00:00.513416 11873 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-26T13:20:10.068335+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-26T12:05:00+00:00 EmrJobFlowSensor 2021-03-26T13:05:52.085645+00:00 2021-03-26T13:14:54.719349+00:00 0:09:02.633704 11871 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-26T13:05:49.900099+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-26T12:05:00+00:00 EmrCreateJobFlowOperator 2021-03-26T13:05:32.044247+00:00 2021-03-26T13:05:33.758524+00:00 0:00:01.714277 11870 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-26T13:05:29.881847+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-26T12:05:00+00:00 PythonOperator 2021-03-26T13:05:10.160253+00:00 2021-03-26T13:05:12.976323+00:00 0:00:02.816070 11869 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-26T13:05:07.865533+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-26T12:00:00+00:00 EmrJobFlowSensor 2021-03-26T13:00:53.835412+00:00 2021-03-26T13:09:56.666557+00:00 0:09:02.831145 11868 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-26T13:00:51.433673+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-26T12:00:00+00:00 EmrCreateJobFlowOperator 2021-03-26T13:00:31.699295+00:00 2021-03-26T13:00:33.395196+00:00 0:00:01.695901 11867 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-26T13:00:29.475150+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-26T12:00:00+00:00 PythonOperator 2021-03-26T13:00:09.649746+00:00 2021-03-26T13:00:12.552502+00:00 0:00:02.902756 11866 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-26T13:00:07.399751+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-26T11:00:00+00:00 EmrJobFlowSensor 2021-03-26T12:18:49.696076+00:00 2021-03-26T12:29:52.649753+00:00 0:11:02.953677 11865 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-26T12:18:47.453115+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-26T11:00:00+00:00 EmrCreateJobFlowOperator 2021-03-26T12:18:27.595546+00:00 2021-03-26T12:18:29.282020+00:00 0:00:01.686474 11864 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-26T12:18:25.428138+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-26T11:00:00+00:00 PythonOperator 2021-03-26T12:18:05.678354+00:00 2021-03-26T12:18:08.612804+00:00 0:00:02.934450 11863 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-26T12:18:03.408620+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-26T11:00:00+00:00 TriggerDagRunOperator 2021-03-26T12:17:41.818581+00:00 2021-03-26T12:17:42.313537+00:00 0:00:00.494956 11862 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-26T12:17:39.461649+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-26T11:00:00+00:00 TriggerDagRunOperator 2021-03-26T12:17:41.713141+00:00 2021-03-26T12:17:42.110789+00:00 0:00:00.397648 11861 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-26T12:17:39.461605+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-26T11:00:00+00:00 EmrJobFlowSensor 2021-03-26T12:08:22.669544+00:00 2021-03-26T12:17:25.277758+00:00 0:09:02.608214 11860 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-26T12:08:20.464676+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-26T11:05:00+00:00 EmrJobFlowSensor 2021-03-26T12:08:04.734945+00:00 2021-03-26T12:17:07.459872+00:00 0:09:02.724927 11859 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-26T12:08:02.449205+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-26T11:00:00+00:00 EmrCreateJobFlowOperator 2021-03-26T12:07:52.652892+00:00 2021-03-26T12:07:54.375413+00:00 0:00:01.722521 11858 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-26T12:07:50.438137+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-26T11:05:00+00:00 EmrCreateJobFlowOperator 2021-03-26T12:07:40.615543+00:00 2021-03-26T12:07:42.369067+00:00 0:00:01.753524 11857 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-26T12:07:38.425242+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-26T11:00:00+00:00 PythonOperator 2021-03-26T12:07:30.753936+00:00 2021-03-26T12:07:33.518332+00:00 0:00:02.764396 11856 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-26T12:07:28.455611+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-26T11:05:00+00:00 PythonOperator 2021-03-26T12:07:20.850920+00:00 2021-03-26T12:07:23.691285+00:00 0:00:02.840365 11855 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-26T12:07:18.461026+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-26T10:00:00+00:00 EmrJobFlowSensor 2021-03-26T11:12:14.343052+00:00 2021-03-26T11:22:17.214975+00:00 0:10:02.871923 11853 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-26T11:12:12.095141+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-26T10:00:00+00:00 EmrCreateJobFlowOperator 2021-03-26T11:11:52.193345+00:00 2021-03-26T11:11:53.994991+00:00 0:00:01.801646 11852 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-26T11:11:50.025255+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-26T10:00:00+00:00 PythonOperator 2021-03-26T11:11:30.528313+00:00 2021-03-26T11:11:33.521009+00:00 0:00:02.992696 11851 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-26T11:11:28.077980+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-26T10:00:00+00:00 TriggerDagRunOperator 2021-03-26T11:11:24.629692+00:00 2021-03-26T11:11:25.053856+00:00 0:00:00.424164 11850 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-26T11:11:22.063828+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-26T10:00:00+00:00 TriggerDagRunOperator 2021-03-26T11:11:24.562931+00:00 2021-03-26T11:11:25.097543+00:00 0:00:00.534612 11849 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-26T11:11:22.063787+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-26T10:05:00+00:00 EmrJobFlowSensor 2021-03-26T11:05:57.654467+00:00 2021-03-26T11:15:00.229416+00:00 0:09:02.574949 11848 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-26T11:05:55.403984+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-26T10:05:00+00:00 EmrCreateJobFlowOperator 2021-03-26T11:05:37.572044+00:00 2021-03-26T11:05:39.214955+00:00 0:00:01.642911 11847 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-26T11:05:35.388330+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-26T10:05:00+00:00 PythonOperator 2021-03-26T11:05:15.483278+00:00 2021-03-26T11:05:18.232840+00:00 0:00:02.749562 11846 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-26T11:05:13.303556+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-26T10:00:00+00:00 EmrJobFlowSensor 2021-03-26T11:00:59.046040+00:00 2021-03-26T11:11:01.846930+00:00 0:10:02.800890 11845 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-26T11:00:56.906493+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-26T10:00:00+00:00 EmrCreateJobFlowOperator 2021-03-26T11:00:39.067632+00:00 2021-03-26T11:00:40.749524+00:00 0:00:01.681892 11844 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-26T11:00:36.887175+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-26T10:00:00+00:00 PythonOperator 2021-03-26T11:00:15.370862+00:00 2021-03-26T11:00:18.245979+00:00 0:00:02.875117 11843 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-26T11:00:12.809792+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-26T09:00:00+00:00 EmrJobFlowSensor 2021-03-26T10:12:09.961353+00:00 2021-03-26T10:22:12.842738+00:00 0:10:02.881385 11841 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-26T10:12:07.629450+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-26T09:00:00+00:00 EmrCreateJobFlowOperator 2021-03-26T10:11:47.786656+00:00 2021-03-26T10:11:49.503109+00:00 0:00:01.716453 11840 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-26T10:11:45.614036+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-26T09:00:00+00:00 PythonOperator 2021-03-26T10:11:25.889032+00:00 2021-03-26T10:11:29.030990+00:00 0:00:03.141958 11839 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-26T10:11:23.641567+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-26T09:00:00+00:00 TriggerDagRunOperator 2021-03-26T10:11:10.189212+00:00 2021-03-26T10:11:10.665394+00:00 0:00:00.476182 11838 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-26T10:11:07.510148+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-26T09:00:00+00:00 TriggerDagRunOperator 2021-03-26T10:11:10.118258+00:00 2021-03-26T10:11:10.697544+00:00 0:00:00.579286 11837 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-26T10:11:07.510115+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-26T09:05:00+00:00 EmrJobFlowSensor 2021-03-26T10:06:07.009017+00:00 2021-03-26T10:15:09.658056+00:00 0:09:02.649039 11836 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-26T10:06:04.888359+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-26T09:05:00+00:00 EmrCreateJobFlowOperator 2021-03-26T10:05:45.128716+00:00 2021-03-26T10:05:46.792560+00:00 0:00:01.663844 11835 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-26T10:05:42.801495+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-26T09:05:00+00:00 PythonOperator 2021-03-26T10:05:23.049082+00:00 2021-03-26T10:05:25.742977+00:00 0:00:02.693895 11834 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-26T10:05:20.788787+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-26T09:00:00+00:00 EmrJobFlowSensor 2021-03-26T10:01:00.868938+00:00 2021-03-26T10:11:03.831638+00:00 0:10:02.962700 11833 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-26T10:00:58.485313+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-26T09:00:00+00:00 EmrCreateJobFlowOperator 2021-03-26T10:00:40.633902+00:00 2021-03-26T10:00:42.449715+00:00 0:00:01.815813 11832 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-26T10:00:38.454896+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-26T09:00:00+00:00 PythonOperator 2021-03-26T10:00:19.018713+00:00 2021-03-26T10:00:21.827792+00:00 0:00:02.809079 11831 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-26T10:00:16.462016+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-26T08:00:00+00:00 EmrJobFlowSensor 2021-03-26T09:11:10.987637+00:00 2021-03-26T09:21:13.834116+00:00 0:10:02.846479 11829 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-26T09:11:08.820326+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-26T08:00:00+00:00 EmrCreateJobFlowOperator 2021-03-26T09:10:46.888247+00:00 2021-03-26T09:10:48.614048+00:00 0:00:01.725801 11828 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-26T09:10:44.794089+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-26T08:00:00+00:00 PythonOperator 2021-03-26T09:10:27.088639+00:00 2021-03-26T09:10:30.129441+00:00 0:00:03.040802 11827 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-26T09:10:24.753826+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-26T08:00:00+00:00 TriggerDagRunOperator 2021-03-26T09:10:19.093476+00:00 2021-03-26T09:10:19.537303+00:00 0:00:00.443827 11826 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-26T09:10:16.749128+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-26T08:00:00+00:00 TriggerDagRunOperator 2021-03-26T09:10:19.023901+00:00 2021-03-26T09:10:19.594705+00:00 0:00:00.570804 11825 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-26T09:10:16.749162+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-26T08:05:00+00:00 EmrJobFlowSensor 2021-03-26T09:05:54.940844+00:00 2021-03-26T09:13:57.372883+00:00 0:08:02.432039 11824 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-26T09:05:52.544233+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-26T08:05:00+00:00 EmrCreateJobFlowOperator 2021-03-26T09:05:34.603032+00:00 2021-03-26T09:05:36.262985+00:00 0:00:01.659953 11823 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-26T09:05:32.403375+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-26T08:05:00+00:00 PythonOperator 2021-03-26T09:05:10.481975+00:00 2021-03-26T09:05:13.233288+00:00 0:00:02.751313 11822 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-26T09:05:08.309324+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-26T08:00:00+00:00 EmrJobFlowSensor 2021-03-26T09:00:54.301227+00:00 2021-03-26T09:09:57.037170+00:00 0:09:02.735943 11821 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-26T09:00:51.923223+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-26T08:00:00+00:00 EmrCreateJobFlowOperator 2021-03-26T09:00:30.538367+00:00 2021-03-26T09:00:32.205931+00:00 0:00:01.667564 11820 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-26T09:00:27.979303+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-26T08:00:00+00:00 PythonOperator 2021-03-26T09:00:08.779789+00:00 2021-03-26T09:00:11.654853+00:00 0:00:02.875064 11819 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-26T09:00:05.951099+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-26T07:00:00+00:00 EmrJobFlowSensor 2021-03-26T08:11:14.389894+00:00 2021-03-26T08:21:17.386091+00:00 0:10:02.996197 11817 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-26T08:11:11.995158+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-26T07:00:00+00:00 EmrCreateJobFlowOperator 2021-03-26T08:10:51.990306+00:00 2021-03-26T08:10:53.748518+00:00 0:00:01.758212 11816 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-26T08:10:49.852151+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-26T07:00:00+00:00 PythonOperator 2021-03-26T08:10:30.595279+00:00 2021-03-26T08:10:33.598671+00:00 0:00:03.003392 11815 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-26T08:10:27.846255+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-26T07:00:00+00:00 TriggerDagRunOperator 2021-03-26T08:10:18.089511+00:00 2021-03-26T08:10:18.506185+00:00 0:00:00.416674 11814 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-26T08:10:15.826730+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-26T07:00:00+00:00 TriggerDagRunOperator 2021-03-26T08:10:18.124625+00:00 2021-03-26T08:10:18.682615+00:00 0:00:00.557990 11813 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-26T08:10:15.826702+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-26T07:05:00+00:00 EmrJobFlowSensor 2021-03-26T08:06:07.473389+00:00 2021-03-26T08:15:10.073178+00:00 0:09:02.599789 11812 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-26T08:06:05.353199+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-26T07:05:00+00:00 EmrCreateJobFlowOperator 2021-03-26T08:05:45.677139+00:00 2021-03-26T08:05:47.306891+00:00 0:00:01.629752 11811 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-26T08:05:43.344468+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-26T07:05:00+00:00 PythonOperator 2021-03-26T08:05:23.746601+00:00 2021-03-26T08:05:26.513492+00:00 0:00:02.766891 11810 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-26T08:05:21.277135+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-26T07:00:00+00:00 EmrJobFlowSensor 2021-03-26T08:01:06.903364+00:00 2021-03-26T08:10:09.654338+00:00 0:09:02.750974 11809 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-26T08:01:04.651645+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-26T07:00:00+00:00 EmrCreateJobFlowOperator 2021-03-26T08:00:40.817466+00:00 2021-03-26T08:00:42.505073+00:00 0:00:01.687607 11808 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-26T08:00:38.594283+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-26T07:00:00+00:00 PythonOperator 2021-03-26T08:00:18.941310+00:00 2021-03-26T08:00:21.757189+00:00 0:00:02.815879 11807 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-26T08:00:16.550415+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-26T06:00:00+00:00 EmrJobFlowSensor 2021-03-26T07:11:00.172641+00:00 2021-03-26T07:22:03.238498+00:00 0:11:03.065857 11805 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-26T07:10:57.784221+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-26T06:00:00+00:00 EmrCreateJobFlowOperator 2021-03-26T07:10:37.980943+00:00 2021-03-26T07:10:39.750182+00:00 0:00:01.769239 11804 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-26T07:10:35.720282+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-26T06:00:00+00:00 PythonOperator 2021-03-26T07:10:13.929279+00:00 2021-03-26T07:10:17.055464+00:00 0:00:03.126185 11803 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-26T07:10:11.687142+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-26T06:00:00+00:00 TriggerDagRunOperator 2021-03-26T07:10:06.089180+00:00 2021-03-26T07:10:06.529873+00:00 0:00:00.440693 11802 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-26T07:10:03.651167+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-26T06:00:00+00:00 TriggerDagRunOperator 2021-03-26T07:10:05.979108+00:00 2021-03-26T07:10:06.539408+00:00 0:00:00.560300 11801 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-26T07:10:03.651127+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-26T06:05:00+00:00 EmrJobFlowSensor 2021-03-26T07:06:09.538806+00:00 2021-03-26T07:14:12.038431+00:00 0:08:02.499625 11800 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-26T07:06:07.341943+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-26T06:05:00+00:00 EmrCreateJobFlowOperator 2021-03-26T07:05:49.471581+00:00 2021-03-26T07:05:51.136074+00:00 0:00:01.664493 11799 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-26T07:05:47.320828+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-26T06:05:00+00:00 PythonOperator 2021-03-26T07:05:23.746095+00:00 2021-03-26T07:05:26.563098+00:00 0:00:02.817003 11798 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-26T07:05:21.299269+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-26T06:00:00+00:00 EmrJobFlowSensor 2021-03-26T07:00:51.030247+00:00 2021-03-26T07:09:53.687979+00:00 0:09:02.657732 11797 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-26T07:00:48.706545+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-26T06:00:00+00:00 EmrCreateJobFlowOperator 2021-03-26T07:00:28.835277+00:00 2021-03-26T07:00:30.562539+00:00 0:00:01.727262 11796 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-26T07:00:26.689317+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-26T06:00:00+00:00 PythonOperator 2021-03-26T07:00:07.000610+00:00 2021-03-26T07:00:09.704696+00:00 0:00:02.704086 11795 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-26T07:00:04.593264+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-26T05:00:00+00:00 EmrJobFlowSensor 2021-03-26T06:12:04.204559+00:00 2021-03-26T06:22:06.888345+00:00 0:10:02.683786 11793 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-26T06:12:01.655385+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-26T05:00:00+00:00 EmrCreateJobFlowOperator 2021-03-26T06:11:41.731910+00:00 2021-03-26T06:11:43.514876+00:00 0:00:01.782966 11792 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-26T06:11:39.525534+00:00 2 default_pool