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_campaign-history-job_v002 2021-04-22T09:00:00+00:00 TriggerDagRunOperator 2021-04-22T10:11:11.950321+00:00 2021-04-22T10:11:12.396611+00:00 0:00:00.446290 19981 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T10:11:09.292506+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-22T09:00:00+00:00 TriggerDagRunOperator 2021-04-22T10:11:11.980700+00:00 2021-04-22T10:11:12.540936+00:00 0:00:00.560236 19980 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T10:11:09.292548+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-22T09:05:00+00:00 EmrJobFlowSensor 2021-04-22T10:05:54.926416+00:00 2021-04-22T10:16:57.895244+00:00 0:11:02.968828 19979 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T10:05:52.641002+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-22T09:05:00+00:00 EmrCreateJobFlowOperator 2021-04-22T10:05:34.925763+00:00 2021-04-22T10:05:36.693358+00:00 0:00:01.767595 19978 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-22T10:05:32.620073+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-22T09:05:00+00:00 PythonOperator 2021-04-22T10:05:12.806677+00:00 2021-04-22T10:05:16.037689+00:00 0:00:03.231012 19977 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-22T10:05:10.587923+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-22T09:00:00+00:00 EmrJobFlowSensor 2021-04-22T10:00:48.515246+00:00 2021-04-22T10:10:51.331581+00:00 0:10:02.816335 19976 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-22T10:00:46.104889+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-22T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-22T10:00:26.225265+00:00 2021-04-22T10:00:27.879747+00:00 0:00:01.654482 19975 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-22T10:00:24.082757+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-22T09:00:00+00:00 PythonOperator 2021-04-22T10:00:06.488139+00:00 2021-04-22T10:00:09.680854+00:00 0:00:03.192715 19974 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-22T10:00:04.032322+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-22T08:00:00+00:00 EmrJobFlowSensor 2021-04-22T09:12:21.838362+00:00 2021-04-22T09:22:24.648575+00:00 0:10:02.810213 19972 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T09:12:19.537256+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-22T08:00:00+00:00 EmrJobFlowSensor 2021-04-22T09:12:17.830173+00:00 2021-04-22T09:21:20.584493+00:00 0:09:02.754320 19971 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T09:12:15.535367+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-22T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-22T09:11:56.169034+00:00 2021-04-22T09:11:57.873901+00:00 0:00:01.704867 19970 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-22T09:11:53.513675+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-22T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-22T09:11:47.698468+00:00 2021-04-22T09:11:49.371909+00:00 0:00:01.673441 19969 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-22T09:11:45.506170+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-22T08:00:00+00:00 PythonOperator 2021-04-22T09:11:28.063318+00:00 2021-04-22T09:11:31.000056+00:00 0:00:02.936738 19968 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-22T09:11:25.491497+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-22T08:00:00+00:00 PythonOperator 2021-04-22T09:11:25.751102+00:00 2021-04-22T09:11:29.295912+00:00 0:00:03.544810 19967 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-22T09:11:23.496333+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-22T08:00:00+00:00 TriggerDagRunOperator 2021-04-22T09:11:09.905922+00:00 2021-04-22T09:11:10.433011+00:00 0:00:00.527089 19966 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T09:11:07.443023+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-22T08:00:00+00:00 TriggerDagRunOperator 2021-04-22T09:11:09.674095+00:00 2021-04-22T09:11:10.099426+00:00 0:00:00.425331 19965 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T09:11:07.442986+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2021-04-20T23:00:00+00:00 EmrJobFlowSensor 2021-04-22T09:11:05.770982+00:00 2021-04-22T09:20:08.528883+00:00 0:09:02.757901 19964 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T09:11:03.437715+00:00 8 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2021-04-20T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-22T09:10:45.813508+00:00 2021-04-22T09:10:47.557311+00:00 0:00:01.743803 19963 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-22T09:10:43.424936+00:00 3 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2021-04-20T23:00:00+00:00 PythonOperator 2021-04-22T09:10:23.826897+00:00 2021-04-22T09:10:27.011936+00:00 0:00:03.185039 19962 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-22T09:10:21.409315+00:00 3 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-22T08:05:00+00:00 EmrJobFlowSensor 2021-04-22T09:06:01.694868+00:00 2021-04-22T09:15:04.360922+00:00 0:09:02.666054 19960 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T09:05:59.260087+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-22T08:05:00+00:00 EmrCreateJobFlowOperator 2021-04-22T09:05:35.321443+00:00 2021-04-22T09:05:36.935970+00:00 0:00:01.614527 19958 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-22T09:05:33.085624+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-22T08:05:00+00:00 PythonOperator 2021-04-22T09:05:11.103215+00:00 2021-04-22T09:05:14.010169+00:00 0:00:02.906954 19957 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-22T09:05:08.988499+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-22T08:00:00+00:00 EmrJobFlowSensor 2021-04-22T09:00:54.724707+00:00 2021-04-22T09:10:57.413006+00:00 0:10:02.688299 19953 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-22T09:00:52.403212+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-22T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-22T09:00:32.797522+00:00 2021-04-22T09:00:34.462911+00:00 0:00:01.665389 19952 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-22T09:00:30.389331+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-22T08:00:00+00:00 PythonOperator 2021-04-22T09:00:11.125512+00:00 2021-04-22T09:00:14.140606+00:00 0:00:03.015094 19951 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-22T09:00:08.355575+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-22T07:00:00+00:00 EmrJobFlowSensor 2021-04-22T08:12:31.513891+00:00 2021-04-22T08:21:34.214765+00:00 0:09:02.700874 19949 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T08:12:28.879247+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-22T07:00:00+00:00 EmrJobFlowSensor 2021-04-22T08:12:23.359730+00:00 2021-04-22T08:22:25.988212+00:00 0:10:02.628482 19948 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T08:12:20.804131+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-22T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-22T08:12:09.130898+00:00 2021-04-22T08:12:10.927556+00:00 0:00:01.796658 19947 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-22T08:12:06.789690+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-22T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-22T08:12:01.513822+00:00 2021-04-22T08:12:03.220055+00:00 0:00:01.706233 19946 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-22T08:11:58.940889+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-22T07:00:00+00:00 PythonOperator 2021-04-22T08:11:46.993563+00:00 2021-04-22T08:11:50.321714+00:00 0:00:03.328151 19945 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-22T08:11:44.771384+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-22T07:00:00+00:00 PythonOperator 2021-04-22T08:11:40.993289+00:00 2021-04-22T08:11:44.306474+00:00 0:00:03.313185 19944 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-22T08:11:38.767131+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-22T07:00:00+00:00 TriggerDagRunOperator 2021-04-22T08:11:25.400901+00:00 2021-04-22T08:11:25.900674+00:00 0:00:00.499773 19943 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T08:11:22.758159+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-22T07:00:00+00:00 TriggerDagRunOperator 2021-04-22T08:11:25.180922+00:00 2021-04-22T08:11:25.590998+00:00 0:00:00.410076 19942 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T08:11:22.758191+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-22T07:05:00+00:00 EmrJobFlowSensor 2021-04-22T08:05:54.580266+00:00 2021-04-22T08:14:57.086781+00:00 0:09:02.506515 19941 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T08:05:52.277585+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-22T07:05:00+00:00 EmrCreateJobFlowOperator 2021-04-22T08:05:32.688321+00:00 2021-04-22T08:05:34.428221+00:00 0:00:01.739900 19940 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-22T08:05:30.261610+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-22T07:05:00+00:00 PythonOperator 2021-04-22T08:05:06.349663+00:00 2021-04-22T08:05:09.511305+00:00 0:00:03.161642 19939 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-22T08:05:04.167481+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-22T07:00:00+00:00 EmrJobFlowSensor 2021-04-22T08:00:56.058544+00:00 2021-04-22T08:10:58.856334+00:00 0:10:02.797790 19938 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-22T08:00:53.855025+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-22T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-22T08:00:36.117112+00:00 2021-04-22T08:00:38.347074+00:00 0:00:02.229962 19937 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-22T08:00:33.838610+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-22T07:00:00+00:00 PythonOperator 2021-04-22T08:00:14.174317+00:00 2021-04-22T08:00:17.150960+00:00 0:00:02.976643 19936 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-22T08:00:11.844118+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-22T06:00:00+00:00 EmrJobFlowSensor 2021-04-22T07:18:03.518073+00:00 2021-04-22T07:28:06.754193+00:00 0:10:03.236120 19935 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T07:18:01.052683+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-22T06:00:00+00:00 EmrJobFlowSensor 2021-04-22T07:17:59.360201+00:00 2021-04-22T07:27:01.983511+00:00 0:09:02.623310 19934 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T07:17:57.047005+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-22T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-22T07:17:41.111477+00:00 2021-04-22T07:17:42.781122+00:00 0:00:01.669645 19933 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-22T07:17:38.972449+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-22T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-22T07:17:37.297997+00:00 2021-04-22T07:17:39.099573+00:00 0:00:01.801576 19932 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-22T07:17:34.923098+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-22T06:00:00+00:00 PythonOperator 2021-04-22T07:17:19.154867+00:00 2021-04-22T07:17:22.071890+00:00 0:00:02.917023 19931 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-22T07:17:16.905235+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-22T06:00:00+00:00 PythonOperator 2021-04-22T07:17:17.160345+00:00 2021-04-22T07:17:20.368046+00:00 0:00:03.207701 19930 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-22T07:17:14.898133+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-22T06:00:00+00:00 TriggerDagRunOperator 2021-04-22T07:17:03.672396+00:00 2021-04-22T07:17:04.206536+00:00 0:00:00.534140 19929 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T07:17:00.883759+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-22T06:00:00+00:00 TriggerDagRunOperator 2021-04-22T07:17:03.463053+00:00 2021-04-22T07:17:03.894536+00:00 0:00:00.431483 19928 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T07:17:00.883728+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-22T06:05:00+00:00 EmrJobFlowSensor 2021-04-22T07:06:33.992883+00:00 2021-04-22T07:14:36.529010+00:00 0:08:02.536127 19923 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T07:06:31.838358+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-22T06:05:00+00:00 EmrCreateJobFlowOperator 2021-04-22T07:06:12.032536+00:00 2021-04-22T07:06:13.672474+00:00 0:00:01.639938 19922 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-22T07:06:09.817663+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-22T06:05:00+00:00 PythonOperator 2021-04-22T07:05:50.249055+00:00 2021-04-22T07:05:53.161018+00:00 0:00:02.911963 19921 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-22T07:05:47.852678+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-22T06:00:00+00:00 EmrJobFlowSensor 2021-04-22T07:01:05.517472+00:00 2021-04-22T07:12:08.416707+00:00 0:11:02.899235 19920 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-22T07:01:03.360176+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-22T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-22T07:00:43.656013+00:00 2021-04-22T07:00:45.487759+00:00 0:00:01.831746 19919 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-22T07:00:41.284018+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-22T06:00:00+00:00 PythonOperator 2021-04-22T07:00:21.516246+00:00 2021-04-22T07:00:24.621562+00:00 0:00:03.105316 19918 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-22T07:00:19.254495+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-22T05:00:00+00:00 EmrJobFlowSensor 2021-04-22T06:12:55.137631+00:00 2021-04-22T06:22:57.919822+00:00 0:10:02.782191 19917 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T06:12:52.754504+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-22T05:00:00+00:00 EmrJobFlowSensor 2021-04-22T06:12:40.888868+00:00 2021-04-22T06:20:43.455281+00:00 0:08:02.566413 19916 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T06:12:38.741652+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-22T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-22T06:12:29.068670+00:00 2021-04-22T06:12:30.851801+00:00 0:00:01.783131 19915 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-22T06:12:26.735265+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-22T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-22T06:12:15.072632+00:00 2021-04-22T06:12:16.754459+00:00 0:00:01.681827 19914 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-22T06:12:12.718741+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-22T05:00:00+00:00 PythonOperator 2021-04-22T06:12:02.907336+00:00 2021-04-22T06:12:06.030232+00:00 0:00:03.122896 19913 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-22T06:12:00.708252+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-22T05:00:00+00:00 PythonOperator 2021-04-22T06:11:53.022682+00:00 2021-04-22T06:11:56.263056+00:00 0:00:03.240374 19912 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-22T06:11:50.700097+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-22T05:05:00+00:00 EmrJobFlowSensor 2021-04-22T06:11:24.874691+00:00 2021-04-22T06:20:27.456055+00:00 0:09:02.581364 19911 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T06:11:22.675631+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-22T05:00:00+00:00 TriggerDagRunOperator 2021-04-22T06:11:21.079234+00:00 2021-04-22T06:11:21.525567+00:00 0:00:00.446333 19910 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T06:11:18.673068+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-22T05:00:00+00:00 TriggerDagRunOperator 2021-04-22T06:11:20.992353+00:00 2021-04-22T06:11:21.534705+00:00 0:00:00.542352 19909 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T06:11:18.673096+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-22T05:05:00+00:00 EmrCreateJobFlowOperator 2021-04-22T06:10:56.903731+00:00 2021-04-22T06:10:58.574311+00:00 0:00:01.670580 19908 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-22T06:10:54.654200+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-22T05:05:00+00:00 PythonOperator 2021-04-22T06:05:10.185294+00:00 2021-04-22T06:05:13.280768+00:00 0:00:03.095474 19906 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-22T06:05:07.843626+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-22T05:00:00+00:00 EmrJobFlowSensor 2021-04-22T06:00:53.817212+00:00 2021-04-22T06:10:56.628485+00:00 0:10:02.811273 19905 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-22T06:00:51.502452+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-22T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-22T06:00:32.736366+00:00 2021-04-22T06:00:34.498781+00:00 0:00:01.762415 19904 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-22T06:00:29.562388+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-22T05:00:00+00:00 PythonOperator 2021-04-22T06:00:09.899403+00:00 2021-04-22T06:00:13.095355+00:00 0:00:03.195952 19903 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-22T06:00:07.443172+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-22T04:00:00+00:00 EmrJobFlowSensor 2021-04-22T05:13:09.037207+00:00 2021-04-22T05:21:11.918202+00:00 0:08:02.880995 19902 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T05:13:06.675804+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-22T04:00:00+00:00 EmrJobFlowSensor 2021-04-22T05:12:54.950072+00:00 2021-04-22T05:22:57.940294+00:00 0:10:02.990222 19901 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T05:12:52.637827+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-22T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-22T05:12:47.098956+00:00 2021-04-22T05:12:48.771518+00:00 0:00:01.672562 19900 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-22T05:12:44.744707+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-22T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-22T05:12:32.886204+00:00 2021-04-22T05:12:34.588534+00:00 0:00:01.702330 19899 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-22T05:12:30.621706+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-22T04:00:00+00:00 PythonOperator 2021-04-22T05:12:25.208693+00:00 2021-04-22T05:12:28.192709+00:00 0:00:02.984016 19898 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-22T05:12:22.667284+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-22T04:00:00+00:00 PythonOperator 2021-04-22T05:12:12.865962+00:00 2021-04-22T05:12:16.011393+00:00 0:00:03.145431 19897 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-22T05:12:10.593393+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-22T04:00:00+00:00 TriggerDagRunOperator 2021-04-22T05:12:07.137664+00:00 2021-04-22T05:12:07.586785+00:00 0:00:00.449121 19896 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T05:12:04.731538+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-22T04:00:00+00:00 TriggerDagRunOperator 2021-04-22T05:12:07.024848+00:00 2021-04-22T05:12:07.591322+00:00 0:00:00.566474 19895 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T05:12:04.731504+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-22T04:05:00+00:00 EmrJobFlowSensor 2021-04-22T05:06:08.378999+00:00 2021-04-22T05:15:11.051356+00:00 0:09:02.672357 19894 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T05:06:06.081343+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-22T04:05:00+00:00 EmrCreateJobFlowOperator 2021-04-22T05:05:48.587207+00:00 2021-04-22T05:05:50.253506+00:00 0:00:01.666299 19893 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-22T05:05:46.055329+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-22T04:05:00+00:00 PythonOperator 2021-04-22T05:05:26.259509+00:00 2021-04-22T05:05:29.184682+00:00 0:00:02.925173 19892 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-22T05:05:24.039157+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-22T04:00:00+00:00 EmrJobFlowSensor 2021-04-22T05:00:47.934120+00:00 2021-04-22T05:11:50.793755+00:00 0:11:02.859635 19890 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-22T05:00:45.582262+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-22T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-22T05:00:27.657433+00:00 2021-04-22T05:00:29.329379+00:00 0:00:01.671946 19889 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-22T05:00:25.505317+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-22T04:00:00+00:00 PythonOperator 2021-04-22T05:00:05.695725+00:00 2021-04-22T05:00:09.015128+00:00 0:00:03.319403 19888 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-22T05:00:03.482922+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-22T03:00:00+00:00 EmrJobFlowSensor 2021-04-22T04:12:24.764076+00:00 2021-04-22T04:21:27.356434+00:00 0:09:02.592358 19887 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T04:12:22.303010+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-22T03:00:00+00:00 EmrJobFlowSensor 2021-04-22T04:12:20.796045+00:00 2021-04-22T04:20:23.319422+00:00 0:08:02.523377 19886 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T04:12:18.310000+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-22T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-22T04:12:04.817654+00:00 2021-04-22T04:12:06.720208+00:00 0:00:01.902554 19885 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-22T04:12:02.288490+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-22T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-22T04:11:58.831230+00:00 2021-04-22T04:12:00.619395+00:00 0:00:01.788165 19884 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-22T04:11:56.236460+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-22T03:00:00+00:00 PythonOperator 2021-04-22T04:11:41.573093+00:00 2021-04-22T04:11:44.927299+00:00 0:00:03.354206 19883 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-22T04:11:38.279817+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-22T03:00:00+00:00 PythonOperator 2021-04-22T04:11:36.723438+00:00 2021-04-22T04:11:40.239746+00:00 0:00:03.516308 19882 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-22T04:11:34.277588+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-22T03:00:00+00:00 TriggerDagRunOperator 2021-04-22T04:11:21.134866+00:00 2021-04-22T04:11:21.636469+00:00 0:00:00.501603 19881 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T04:11:18.258376+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-22T03:00:00+00:00 TriggerDagRunOperator 2021-04-22T04:11:20.791755+00:00 2021-04-22T04:11:21.295650+00:00 0:00:00.503895 19880 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T04:11:18.258426+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-22T03:05:00+00:00 EmrJobFlowSensor 2021-04-22T04:06:07.950471+00:00 2021-04-22T04:14:10.532516+00:00 0:08:02.582045 19879 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T04:06:05.695622+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-22T03:05:00+00:00 EmrCreateJobFlowOperator 2021-04-22T04:05:45.845472+00:00 2021-04-22T04:05:47.468560+00:00 0:00:01.623088 19878 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-22T04:05:43.643543+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-22T03:05:00+00:00 PythonOperator 2021-04-22T04:05:18.029038+00:00 2021-04-22T04:05:20.993757+00:00 0:00:02.964719 19877 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-22T04:05:15.621450+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-22T03:00:00+00:00 EmrJobFlowSensor 2021-04-22T04:01:12.610022+00:00 2021-04-22T04:11:15.613522+00:00 0:10:03.003500 19875 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-22T04:01:10.285889+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-22T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-22T04:00:50.498629+00:00 2021-04-22T04:00:52.187794+00:00 0:00:01.689165 19874 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-22T04:00:48.270436+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-22T03:00:00+00:00 PythonOperator 2021-04-22T04:00:19.030422+00:00 2021-04-22T04:00:21.999930+00:00 0:00:02.969508 19873 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-22T04:00:16.245683+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-22T02:00:00+00:00 EmrJobFlowSensor 2021-04-22T03:13:41.950702+00:00 2021-04-22T03:22:44.593922+00:00 0:09:02.643220 19872 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T03:13:39.693239+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-22T02:00:00+00:00 EmrJobFlowSensor 2021-04-22T03:13:38.437759+00:00 2021-04-22T03:23:41.181437+00:00 0:10:02.743678 19871 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T03:13:35.753408+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-22T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-22T03:13:21.836810+00:00 2021-04-22T03:13:23.523086+00:00 0:00:01.686276 19870 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-22T03:13:19.669459+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-22T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-22T03:13:17.823980+00:00 2021-04-22T03:13:19.539359+00:00 0:00:01.715379 19869 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-22T03:13:15.658177+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-22T02:00:00+00:00 PythonOperator 2021-04-22T03:12:59.984078+00:00 2021-04-22T03:13:03.150974+00:00 0:00:03.166896 19868 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-22T03:12:57.655742+00:00 2 default_pool