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-07-03T04:00:00+00:00 PythonOperator 2021-07-03T05:11:18.399992+00:00 2021-07-03T05:11:22.632875+00:00 0:00:04.232883 49114 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-03T05:11:15.067284+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-07-03T04:00:00+00:00 PythonOperator 2021-07-03T05:11:16.103721+00:00 2021-07-03T05:11:20.233409+00:00 0:00:04.129688 49113 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-03T05:11:13.062177+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-07-03T04:00:00+00:00 TriggerDagRunOperator 2021-07-03T05:11:07.524889+00:00 2021-07-03T05:11:08.149578+00:00 0:00:00.624689 49112 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-03T05:11:05.055284+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-07-03T04:00:00+00:00 TriggerDagRunOperator 2021-07-03T05:11:07.265208+00:00 2021-07-03T05:11:07.663703+00:00 0:00:00.398495 49111 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-03T05:11:05.055256+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-07-03T04:05:00+00:00 EmrJobFlowSensor 2021-07-03T05:06:04.932536+00:00 2021-07-03T05:15:07.654419+00:00 0:09:02.721883 49110 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-03T05:06:02.445611+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-07-03T04:05:00+00:00 EmrCreateJobFlowOperator 2021-07-03T05:05:42.716267+00:00 2021-07-03T05:05:44.485350+00:00 0:00:01.769083 49109 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-03T05:05:40.353990+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-07-03T04:05:00+00:00 PythonOperator 2021-07-03T05:05:20.547300+00:00 2021-07-03T05:05:24.245128+00:00 0:00:03.697828 49108 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-03T05:05:18.346439+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-07-03T04:00:00+00:00 EmrJobFlowSensor 2021-07-03T05:01:00.249318+00:00 2021-07-03T05:11:03.309238+00:00 0:10:03.059920 49107 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-03T05:00:57.840814+00:00 2 default_pool
success livepop-shuffle-job_v002 check_cluster_status 2021-07-03T04:00:00+00:00 EmrJobFlowSensor 2021-07-03T05:00:54.124940+00:00 2021-07-03T05:10:56.927402+00:00 0:10:02.802462 49106 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-03T05:00:51.782723+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-07-03T04:00:00+00:00 EmrCreateJobFlowOperator 2021-07-03T05:00:40.137503+00:00 2021-07-03T05:00:41.953685+00:00 0:00:01.816182 49105 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-07-03T05:00:37.762874+00:00 2 default_pool
success livepop-shuffle-job_v002 create_cluster_and_add_emr_steps 2021-07-03T04:00:00+00:00 EmrCreateJobFlowOperator 2021-07-03T05:00:34.140394+00:00 2021-07-03T05:00:35.946265+00:00 0:00:01.805871 49104 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-03T05:00:31.757460+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-07-03T04:00:00+00:00 PythonOperator 2021-07-03T05:00:15.896901+00:00 2021-07-03T05:00:19.513636+00:00 0:00:03.616735 49103 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-07-03T05:00:13.704620+00:00 2 default_pool
success livepop-shuffle-job_v002 create_emr_steps 2021-07-03T04:00:00+00:00 PythonOperator 2021-07-03T05:00:10.562838+00:00 2021-07-03T05:00:13.964332+00:00 0:00:03.401494 49102 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-03T05:00:07.769694+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-07-03T03:00:00+00:00 EmrJobFlowSensor 2021-07-03T04:11:52.810313+00:00 2021-07-03T04:20:55.665107+00:00 0:09:02.854794 49100 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-03T04:11:50.399279+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-07-03T03:00:00+00:00 EmrJobFlowSensor 2021-07-03T04:11:52.586094+00:00 2021-07-03T04:21:55.650463+00:00 0:10:03.064369 49099 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-03T04:11:50.399248+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-07-03T03:00:00+00:00 EmrCreateJobFlowOperator 2021-07-03T04:11:33.055968+00:00 2021-07-03T04:11:34.794906+00:00 0:00:01.738938 49098 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-03T04:11:30.377829+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-07-03T03:00:00+00:00 EmrCreateJobFlowOperator 2021-07-03T04:11:30.652147+00:00 2021-07-03T04:11:32.693065+00:00 0:00:02.040918 49097 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-03T04:11:28.369271+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-07-03T03:00:00+00:00 PythonOperator 2021-07-03T04:11:10.638539+00:00 2021-07-03T04:11:14.298600+00:00 0:00:03.660061 49096 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-03T04:11:08.346416+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-07-03T03:00:00+00:00 PythonOperator 2021-07-03T04:11:08.632810+00:00 2021-07-03T04:11:12.337566+00:00 0:00:03.704756 49095 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-03T04:11:06.370862+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-07-03T03:00:00+00:00 TriggerDagRunOperator 2021-07-03T04:11:05.220028+00:00 2021-07-03T04:11:05.621907+00:00 0:00:00.401879 49094 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-03T04:11:02.364179+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-07-03T03:00:00+00:00 TriggerDagRunOperator 2021-07-03T04:11:05.116277+00:00 2021-07-03T04:11:05.644228+00:00 0:00:00.527951 49093 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-03T04:11:02.364134+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-07-03T03:05:00+00:00 EmrJobFlowSensor 2021-07-03T04:06:03.918049+00:00 2021-07-03T04:15:06.512257+00:00 0:09:02.594208 49092 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-03T04:06:01.739428+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-07-03T03:05:00+00:00 EmrCreateJobFlowOperator 2021-07-03T04:05:41.909334+00:00 2021-07-03T04:05:43.587189+00:00 0:00:01.677855 49091 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-03T04:05:39.720068+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-07-03T03:05:00+00:00 PythonOperator 2021-07-03T04:05:20.158700+00:00 2021-07-03T04:05:23.106281+00:00 0:00:02.947581 49090 airflow-worker-2.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-03T04:05:17.708731+00:00 2 default_pool
success livepop-shuffle-job_v002 check_cluster_status 2021-07-03T03:00:00+00:00 EmrJobFlowSensor 2021-07-03T04:01:07.600052+00:00 2021-07-03T04:11:10.438291+00:00 0:10:02.838239 49089 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-03T04:01:05.451803+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-07-03T03:00:00+00:00 EmrJobFlowSensor 2021-07-03T04:00:51.656168+00:00 2021-07-03T04:10:54.713619+00:00 0:10:03.057451 49088 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-03T04:00:49.308673+00:00 2 default_pool
success livepop-shuffle-job_v002 create_cluster_and_add_emr_steps 2021-07-03T03:00:00+00:00 EmrCreateJobFlowOperator 2021-07-03T04:00:45.667624+00:00 2021-07-03T04:00:47.442783+00:00 0:00:01.775159 49087 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-03T04:00:43.304782+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-07-03T03:00:00+00:00 EmrCreateJobFlowOperator 2021-07-03T04:00:29.706082+00:00 2021-07-03T04:00:31.441753+00:00 0:00:01.735671 49086 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-07-03T04:00:27.291723+00:00 2 default_pool
success livepop-shuffle-job_v002 create_emr_steps 2021-07-03T03:00:00+00:00 PythonOperator 2021-07-03T04:00:23.495635+00:00 2021-07-03T04:00:27.237476+00:00 0:00:03.741841 49085 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-03T04:00:21.283879+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-07-03T03:00:00+00:00 PythonOperator 2021-07-03T04:00:08.089196+00:00 2021-07-03T04:00:11.542053+00:00 0:00:03.452857 49084 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-07-03T04:00:05.176318+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-07-03T02:00:00+00:00 EmrJobFlowSensor 2021-07-03T03:11:13.419413+00:00 2021-07-03T03:21:16.380826+00:00 0:10:02.961413 49082 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-03T03:11:11.104506+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-07-03T02:00:00+00:00 EmrJobFlowSensor 2021-07-03T03:11:01.453214+00:00 2021-07-03T03:21:04.366357+00:00 0:10:02.913143 49081 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-03T03:10:59.162578+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-07-03T02:00:00+00:00 EmrCreateJobFlowOperator 2021-07-03T03:10:51.295888+00:00 2021-07-03T03:10:53.137962+00:00 0:00:01.842074 49080 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-03T03:10:49.082413+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-07-03T02:00:00+00:00 EmrCreateJobFlowOperator 2021-07-03T03:10:39.758156+00:00 2021-07-03T03:10:41.463068+00:00 0:00:01.704912 49079 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-03T03:10:37.041128+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-07-03T02:00:00+00:00 PythonOperator 2021-07-03T03:10:31.216178+00:00 2021-07-03T03:10:35.070637+00:00 0:00:03.854459 49078 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-03T03:10:29.067533+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-07-03T02:00:00+00:00 PythonOperator 2021-07-03T03:10:17.266646+00:00 2021-07-03T03:10:20.617365+00:00 0:00:03.350719 49077 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-03T03:10:15.029747+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-07-03T02:00:00+00:00 TriggerDagRunOperator 2021-07-03T03:10:07.313679+00:00 2021-07-03T03:10:07.811863+00:00 0:00:00.498184 49076 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-03T03:10:05.014661+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-07-03T02:00:00+00:00 TriggerDagRunOperator 2021-07-03T03:10:07.163184+00:00 2021-07-03T03:10:07.537122+00:00 0:00:00.373938 49075 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-03T03:10:05.014630+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-07-03T02:05:00+00:00 EmrJobFlowSensor 2021-07-03T03:06:06.752768+00:00 2021-07-03T03:16:09.484527+00:00 0:10:02.731759 49074 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-03T03:06:04.618984+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-07-03T02:05:00+00:00 EmrCreateJobFlowOperator 2021-07-03T03:05:42.884018+00:00 2021-07-03T03:05:44.516718+00:00 0:00:01.632700 49073 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-03T03:05:40.649056+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-07-03T02:05:00+00:00 PythonOperator 2021-07-03T03:05:12.678991+00:00 2021-07-03T03:05:16.017850+00:00 0:00:03.338859 49072 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-03T03:05:10.524827+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-07-03T02:00:00+00:00 EmrJobFlowSensor 2021-07-03T03:00:54.613976+00:00 2021-07-03T03:09:57.255869+00:00 0:09:02.641893 49071 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-03T03:00:52.157361+00:00 2 default_pool
success livepop-shuffle-job_v002 check_cluster_status 2021-07-03T02:00:00+00:00 EmrJobFlowSensor 2021-07-03T03:00:50.408502+00:00 2021-07-03T03:11:53.260063+00:00 0:11:02.851561 49070 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-03T03:00:48.140635+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-07-03T02:00:00+00:00 EmrCreateJobFlowOperator 2021-07-03T03:00:28.300705+00:00 2021-07-03T03:00:30.063605+00:00 0:00:01.762900 49069 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-07-03T03:00:26.107183+00:00 2 default_pool
success livepop-shuffle-job_v002 create_cluster_and_add_emr_steps 2021-07-03T02:00:00+00:00 EmrCreateJobFlowOperator 2021-07-03T03:00:26.546950+00:00 2021-07-03T03:00:28.337387+00:00 0:00:01.790437 49068 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-03T03:00:24.169367+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-07-03T02:00:00+00:00 PythonOperator 2021-07-03T03:00:09.253825+00:00 2021-07-03T03:00:13.299923+00:00 0:00:04.046098 49067 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-07-03T03:00:06.091384+00:00 2 default_pool
success livepop-shuffle-job_v002 create_emr_steps 2021-07-03T02:00:00+00:00 PythonOperator 2021-07-03T03:00:04.748189+00:00 2021-07-03T03:00:10.047186+00:00 0:00:05.298997 49066 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-03T03:00:02.156071+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-07-03T01:00:00+00:00 EmrJobFlowSensor 2021-07-03T02:12:29.036758+00:00 2021-07-03T02:22:31.971606+00:00 0:10:02.934848 49064 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-03T02:12:26.806327+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-07-03T01:00:00+00:00 EmrJobFlowSensor 2021-07-03T02:12:21.004508+00:00 2021-07-03T02:21:23.815003+00:00 0:09:02.810495 49063 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-03T02:12:18.798277+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-07-03T01:00:00+00:00 EmrCreateJobFlowOperator 2021-07-03T02:12:08.964071+00:00 2021-07-03T02:12:10.670791+00:00 0:00:01.706720 49062 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-03T02:12:06.787945+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-07-03T01:00:00+00:00 EmrCreateJobFlowOperator 2021-07-03T02:11:58.932378+00:00 2021-07-03T02:12:00.611819+00:00 0:00:01.679441 49061 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-03T02:11:56.735884+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-07-03T01:00:00+00:00 PythonOperator 2021-07-03T02:11:45.186624+00:00 2021-07-03T02:11:48.873145+00:00 0:00:03.686521 49060 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-03T02:11:42.725448+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-07-03T01:00:00+00:00 PythonOperator 2021-07-03T02:11:37.045655+00:00 2021-07-03T02:11:40.719855+00:00 0:00:03.674200 49059 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-03T02:11:34.779471+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-07-03T01:00:00+00:00 TriggerDagRunOperator 2021-07-03T02:11:31.409004+00:00 2021-07-03T02:11:31.918444+00:00 0:00:00.509440 49058 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-03T02:11:28.762099+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-07-03T01:00:00+00:00 TriggerDagRunOperator 2021-07-03T02:11:31.172454+00:00 2021-07-03T02:11:31.563987+00:00 0:00:00.391533 49057 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-03T02:11:28.762044+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-07-03T01:05:00+00:00 EmrJobFlowSensor 2021-07-03T02:05:54.291738+00:00 2021-07-03T02:14:56.919349+00:00 0:09:02.627611 49056 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-03T02:05:52.123388+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-07-03T01:05:00+00:00 EmrCreateJobFlowOperator 2021-07-03T02:05:32.188758+00:00 2021-07-03T02:05:33.797026+00:00 0:00:01.608268 49055 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-03T02:05:30.083085+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-07-03T01:05:00+00:00 PythonOperator 2021-07-03T02:05:10.274256+00:00 2021-07-03T02:05:13.888358+00:00 0:00:03.614102 49054 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-03T02:05:08.020137+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-07-03T01:00:00+00:00 EmrJobFlowSensor 2021-07-03T02:01:05.994088+00:00 2021-07-03T02:11:08.925169+00:00 0:10:02.931081 49053 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-03T02:01:03.637053+00:00 2 default_pool
success livepop-shuffle-job_v002 check_cluster_status 2021-07-03T01:00:00+00:00 EmrJobFlowSensor 2021-07-03T02:00:47.735370+00:00 2021-07-03T02:10:50.553141+00:00 0:10:02.817771 49052 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-03T02:00:45.610054+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-07-03T01:00:00+00:00 EmrCreateJobFlowOperator 2021-07-03T02:00:43.815578+00:00 2021-07-03T02:00:45.567750+00:00 0:00:01.752172 49051 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-07-03T02:00:41.607121+00:00 2 default_pool
success livepop-shuffle-job_v002 create_cluster_and_add_emr_steps 2021-07-03T01:00:00+00:00 EmrCreateJobFlowOperator 2021-07-03T02:00:27.063612+00:00 2021-07-03T02:00:28.770365+00:00 0:00:01.706753 49050 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-03T02:00:23.653269+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-07-03T01:00:00+00:00 PythonOperator 2021-07-03T02:00:21.991015+00:00 2021-07-03T02:00:26.743184+00:00 0:00:04.752169 49049 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-07-03T02:00:19.657256+00:00 2 default_pool
success livepop-shuffle-job_v002 create_emr_steps 2021-07-03T01:00:00+00:00 PythonOperator 2021-07-03T02:00:04.361723+00:00 2021-07-03T02:00:07.780534+00:00 0:00:03.418811 49048 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-03T02:00:01.555876+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-07-03T00:00:00+00:00 EmrJobFlowSensor 2021-07-03T01:10:37.809804+00:00 2021-07-03T01:19:40.484829+00:00 0:09:02.675025 49046 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-03T01:10:35.687128+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-07-03T00:00:00+00:00 EmrJobFlowSensor 2021-07-03T01:10:35.988837+00:00 2021-07-03T01:19:38.877940+00:00 0:09:02.889103 49045 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-03T01:10:33.690027+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-07-03T00:00:00+00:00 EmrCreateJobFlowOperator 2021-07-03T01:10:16.340648+00:00 2021-07-03T01:10:18.065334+00:00 0:00:01.724686 49044 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-03T01:10:13.594846+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-07-03T00:00:00+00:00 EmrCreateJobFlowOperator 2021-07-03T01:10:12.080301+00:00 2021-07-03T01:10:13.960206+00:00 0:00:01.879905 49043 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-03T01:10:09.662364+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-07-03T00:00:00+00:00 PythonOperator 2021-07-03T01:09:51.754261+00:00 2021-07-03T01:09:55.097125+00:00 0:00:03.342864 49042 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-03T01:09:49.527594+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-07-03T00:00:00+00:00 PythonOperator 2021-07-03T01:09:50.008674+00:00 2021-07-03T01:09:53.901818+00:00 0:00:03.893144 49041 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-03T01:09:47.591767+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-07-03T00:00:00+00:00 TriggerDagRunOperator 2021-07-03T01:09:38.114228+00:00 2021-07-03T01:09:38.670782+00:00 0:00:00.556554 49040 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-03T01:09:35.568108+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-07-03T00:00:00+00:00 TriggerDagRunOperator 2021-07-03T01:09:38.014748+00:00 2021-07-03T01:09:38.408949+00:00 0:00:00.394201 49039 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-03T01:09:35.568061+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-07-03T00:05:00+00:00 EmrJobFlowSensor 2021-07-03T01:05:47.262829+00:00 2021-07-03T01:13:49.939028+00:00 0:08:02.676199 49038 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-03T01:05:45.196112+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-07-03T00:05:00+00:00 EmrCreateJobFlowOperator 2021-07-03T01:05:25.365744+00:00 2021-07-03T01:05:27.146363+00:00 0:00:01.780619 49037 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-03T01:05:23.133443+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-07-03T00:05:00+00:00 PythonOperator 2021-07-03T01:05:03.405121+00:00 2021-07-03T01:05:06.739089+00:00 0:00:03.333968 49036 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-03T01:05:01.092617+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-07-03T00:00:00+00:00 EmrJobFlowSensor 2021-07-03T01:00:58.902007+00:00 2021-07-03T01:09:01.635641+00:00 0:08:02.733634 49035 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-03T01:00:56.507206+00:00 2 default_pool
success livepop-shuffle-job_v002 check_cluster_status 2021-07-03T00:00:00+00:00 EmrJobFlowSensor 2021-07-03T01:00:48.829195+00:00 2021-07-03T01:10:51.617267+00:00 0:10:02.788072 49034 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-03T01:00:46.546223+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-07-03T00:00:00+00:00 EmrCreateJobFlowOperator 2021-07-03T01:00:38.734048+00:00 2021-07-03T01:00:40.442817+00:00 0:00:01.708769 49033 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-07-03T01:00:36.487946+00:00 2 default_pool
success livepop-shuffle-job_v002 create_cluster_and_add_emr_steps 2021-07-03T00:00:00+00:00 EmrCreateJobFlowOperator 2021-07-03T01:00:29.068700+00:00 2021-07-03T01:00:30.878403+00:00 0:00:01.809703 49032 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-03T01:00:26.552542+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-07-03T00:00:00+00:00 PythonOperator 2021-07-03T01:00:16.689795+00:00 2021-07-03T01:00:20.089970+00:00 0:00:03.400175 49031 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-07-03T01:00:14.431248+00:00 2 default_pool
success livepop-shuffle-job_v002 create_emr_steps 2021-07-03T00:00:00+00:00 PythonOperator 2021-07-03T01:00:07.083269+00:00 2021-07-03T01:00:10.742009+00:00 0:00:03.658740 49030 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-03T01:00:04.418033+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-07-02T23:00:00+00:00 EmrJobFlowSensor 2021-07-03T00:11:21.195209+00:00 2021-07-03T00:20:24.052511+00:00 0:09:02.857302 49028 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-03T00:11:18.908459+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-07-02T23:00:00+00:00 EmrJobFlowSensor 2021-07-03T00:11:19.131670+00:00 2021-07-03T00:21:21.893012+00:00 0:10:02.761342 49027 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-03T00:11:16.897016+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-07-02T23:00:00+00:00 EmrCreateJobFlowOperator 2021-07-03T00:10:59.219223+00:00 2021-07-03T00:11:00.920617+00:00 0:00:01.701394 49026 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-03T00:10:56.852229+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-07-02T23:00:00+00:00 EmrCreateJobFlowOperator 2021-07-03T00:10:57.202437+00:00 2021-07-03T00:10:59.074020+00:00 0:00:01.871583 49025 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-03T00:10:54.845386+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-07-02T23:00:00+00:00 PythonOperator 2021-07-03T00:10:39.199309+00:00 2021-07-03T00:10:43.101774+00:00 0:00:03.902465 49024 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-03T00:10:36.840822+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-07-02T23:00:00+00:00 PythonOperator 2021-07-03T00:10:37.438429+00:00 2021-07-03T00:10:40.800054+00:00 0:00:03.361625 49023 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-03T00:10:34.844083+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-07-02T23:00:00+00:00 TriggerDagRunOperator 2021-07-03T00:10:29.332729+00:00 2021-07-03T00:10:29.730086+00:00 0:00:00.397357 49022 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-03T00:10:26.755397+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-07-02T23:00:00+00:00 TriggerDagRunOperator 2021-07-03T00:10:29.197030+00:00 2021-07-03T00:10:29.695259+00:00 0:00:00.498229 49021 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-03T00:10:26.755353+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-07-02T23:05:00+00:00 EmrJobFlowSensor 2021-07-03T00:06:00.457123+00:00 2021-07-03T00:14:02.937478+00:00 0:08:02.480355 49020 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-03T00:05:58.251479+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-07-02T23:05:00+00:00 EmrCreateJobFlowOperator 2021-07-03T00:05:38.633594+00:00 2021-07-03T00:05:40.379128+00:00 0:00:01.745534 49019 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-03T00:05:36.209459+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-07-02T23:05:00+00:00 PythonOperator 2021-07-03T00:05:10.617119+00:00 2021-07-03T00:05:14.056083+00:00 0:00:03.438964 49018 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-03T00:05:08.246643+00:00 2 default_pool
success livepop-shuffle-job_v002 check_cluster_status 2021-07-02T23:00:00+00:00 EmrJobFlowSensor 2021-07-03T00:00:56.104564+00:00 2021-07-03T00:10:59.031732+00:00 0:10:02.927168 49017 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-03T00:00:53.857087+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-07-02T23:00:00+00:00 EmrJobFlowSensor 2021-07-03T00:00:54.069989+00:00 2021-07-03T00:09:56.941921+00:00 0:09:02.871932 49016 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-03T00:00:51.784927+00:00 2 default_pool
success livepop-shuffle-job_v002 create_cluster_and_add_emr_steps 2021-07-02T23:00:00+00:00 EmrCreateJobFlowOperator 2021-07-03T00:00:36.123186+00:00 2021-07-03T00:00:37.926150+00:00 0:00:01.802964 49015 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-03T00:00:33.720320+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-07-02T23:00:00+00:00 EmrCreateJobFlowOperator 2021-07-03T00:00:32.418710+00:00 2021-07-03T00:00:34.186379+00:00 0:00:01.767669 49014 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-07-03T00:00:29.854301+00:00 2 default_pool
success livepop-shuffle-job_v002 create_emr_steps 2021-07-02T23:00:00+00:00 PythonOperator 2021-07-03T00:00:11.904542+00:00 2021-07-03T00:00:15.558226+00:00 0:00:03.653684 49013 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-03T00:00:09.698991+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-07-02T23:00:00+00:00 PythonOperator 2021-07-03T00:00:10.124314+00:00 2021-07-03T00:00:13.539507+00:00 0:00:03.415193 49012 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-07-03T00:00:07.703235+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-07-02T22:00:00+00:00 EmrJobFlowSensor 2021-07-02T23:10:55.783993+00:00 2021-07-02T23:20:58.561704+00:00 0:10:02.777711 49010 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-02T23:10:53.623467+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-07-02T22:00:00+00:00 EmrJobFlowSensor 2021-07-02T23:10:50.043913+00:00 2021-07-02T23:20:53.044802+00:00 0:10:03.000889 49009 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-02T23:10:47.619228+00:00 2 default_pool