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 2020-10-30T11:00:00+00:00 PythonOperator 2020-10-30T12:00:11.239202+00:00 2020-10-30T12:00:14.202671+00:00 0:00:02.963469 4954 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2020-10-30T12:00:09.420442+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2020-10-30T10:00:00+00:00 EmrJobFlowSensor 2020-10-30T11:00:26.092255+00:00 2020-10-30T11:12:29.191868+00:00 0:12:03.099613 4952 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-10-30T11:00:24.362333+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2020-10-30T10:00:00+00:00 EmrCreateJobFlowOperator 2020-10-30T11:00:18.141556+00:00 2020-10-30T11:00:19.920815+00:00 0:00:01.779259 4951 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2020-10-30T11:00:16.365854+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2020-10-30T10:00:00+00:00 PythonOperator 2020-10-30T11:00:08.187935+00:00 2020-10-30T11:00:11.136739+00:00 0:00:02.948804 4950 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2020-10-30T11:00:06.343388+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2020-10-30T09:00:00+00:00 EmrJobFlowSensor 2020-10-30T10:00:27.053478+00:00 2020-10-30T10:12:30.294740+00:00 0:12:03.241262 4948 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-10-30T10:00:25.276961+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2020-10-30T09:00:00+00:00 EmrCreateJobFlowOperator 2020-10-30T10:00:19.020572+00:00 2020-10-30T10:00:20.815177+00:00 0:00:01.794605 4947 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2020-10-30T10:00:17.236919+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2020-10-30T09:00:00+00:00 PythonOperator 2020-10-30T10:00:09.066725+00:00 2020-10-30T10:00:11.964595+00:00 0:00:02.897870 4946 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2020-10-30T10:00:07.229799+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2020-10-30T08:00:00+00:00 EmrJobFlowSensor 2020-10-30T09:00:44.002634+00:00 2020-10-30T09:12:47.048353+00:00 0:12:03.045719 4944 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-10-30T09:00:42.242469+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2020-10-30T08:00:00+00:00 EmrCreateJobFlowOperator 2020-10-30T09:00:25.893211+00:00 2020-10-30T09:00:27.608593+00:00 0:00:01.715382 4943 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2020-10-30T09:00:24.207465+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2020-10-30T08:00:00+00:00 PythonOperator 2020-10-30T09:00:08.013139+00:00 2020-10-30T09:00:11.045073+00:00 0:00:03.031934 4942 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2020-10-30T09:00:06.186699+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2020-10-30T07:00:00+00:00 EmrJobFlowSensor 2020-10-30T08:00:31.001120+00:00 2020-10-30T08:12:34.148558+00:00 0:12:03.147438 4940 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-10-30T08:00:29.039563+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2020-10-30T07:00:00+00:00 EmrCreateJobFlowOperator 2020-10-30T08:00:20.993342+00:00 2020-10-30T08:00:22.691742+00:00 0:00:01.698400 4939 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2020-10-30T08:00:19.041964+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2020-10-30T07:00:00+00:00 PythonOperator 2020-10-30T08:00:10.891448+00:00 2020-10-30T08:00:13.843947+00:00 0:00:02.952499 4938 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2020-10-30T08:00:09.012614+00:00 2 default_pool
success missing-dr-check-job_v002 check_cluster_status 2020-10-29T07:30:00+00:00 EmrJobFlowSensor 2020-10-30T07:30:23.933726+00:00 2020-10-30T07:39:26.540344+00:00 0:09:02.606618 4936 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-10-30T07:30:22.282949+00:00 2 default_pool
success missing-dr-check-job_v002 create_cluster_and_add_emr_steps 2020-10-29T07:30:00+00:00 EmrCreateJobFlowOperator 2020-10-30T07:30:14.147323+00:00 2020-10-30T07:30:15.806946+00:00 0:00:01.659623 4935 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2020-10-30T07:30:12.276099+00:00 2 default_pool
success missing-dr-check-job_v002 create_emr_steps 2020-10-29T07:30:00+00:00 PythonOperator 2020-10-30T07:30:03.925838+00:00 2020-10-30T07:30:06.571048+00:00 0:00:02.645210 4934 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2020-10-30T07:30:02.265452+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2020-10-30T06:00:00+00:00 EmrJobFlowSensor 2020-10-30T07:00:22.295484+00:00 2020-10-30T07:12:25.406581+00:00 0:12:03.111097 4933 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-10-30T07:00:20.577633+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2020-10-30T06:00:00+00:00 EmrCreateJobFlowOperator 2020-10-30T07:00:12.333960+00:00 2020-10-30T07:00:14.070444+00:00 0:00:01.736484 4932 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2020-10-30T07:00:10.583484+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2020-10-30T06:00:00+00:00 PythonOperator 2020-10-30T07:00:04.342057+00:00 2020-10-30T07:00:07.257705+00:00 0:00:02.915648 4931 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2020-10-30T07:00:02.562313+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2020-10-30T05:00:00+00:00 EmrJobFlowSensor 2020-10-30T06:00:25.060005+00:00 2020-10-30T06:12:28.145534+00:00 0:12:03.085529 4929 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-10-30T06:00:23.352114+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2020-10-30T05:00:00+00:00 EmrCreateJobFlowOperator 2020-10-30T06:00:15.192442+00:00 2020-10-30T06:00:16.973516+00:00 0:00:01.781074 4928 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2020-10-30T06:00:13.338227+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2020-10-30T05:00:00+00:00 PythonOperator 2020-10-30T06:00:07.215432+00:00 2020-10-30T06:00:10.154958+00:00 0:00:02.939526 4927 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2020-10-30T06:00:05.325822+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2020-10-30T04:00:00+00:00 EmrJobFlowSensor 2020-10-30T05:00:26.378056+00:00 2020-10-30T05:12:29.535292+00:00 0:12:03.157236 4925 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-10-30T05:00:24.709863+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2020-10-30T04:00:00+00:00 EmrCreateJobFlowOperator 2020-10-30T05:00:18.522710+00:00 2020-10-30T05:00:20.281869+00:00 0:00:01.759159 4924 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2020-10-30T05:00:16.679316+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2020-10-30T04:00:00+00:00 PythonOperator 2020-10-30T05:00:08.395571+00:00 2020-10-30T05:00:11.384019+00:00 0:00:02.988448 4923 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2020-10-30T05:00:06.673458+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2020-10-30T03:00:00+00:00 EmrJobFlowSensor 2020-10-30T04:00:23.571704+00:00 2020-10-30T04:12:26.710869+00:00 0:12:03.139165 4921 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-10-30T04:00:21.831100+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2020-10-30T03:00:00+00:00 EmrCreateJobFlowOperator 2020-10-30T04:00:13.686390+00:00 2020-10-30T04:00:15.418098+00:00 0:00:01.731708 4920 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2020-10-30T04:00:11.819414+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2020-10-30T03:00:00+00:00 PythonOperator 2020-10-30T04:00:05.996258+00:00 2020-10-30T04:00:08.918819+00:00 0:00:02.922561 4919 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2020-10-30T04:00:03.854449+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2020-10-30T02:00:00+00:00 EmrJobFlowSensor 2020-10-30T03:00:32.701673+00:00 2020-10-30T03:12:35.821532+00:00 0:12:03.119859 4917 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-10-30T03:00:30.850703+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2020-10-30T02:00:00+00:00 EmrCreateJobFlowOperator 2020-10-30T03:00:22.604537+00:00 2020-10-30T03:00:24.380819+00:00 0:00:01.776282 4916 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2020-10-30T03:00:20.847713+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2020-10-30T02:00:00+00:00 PythonOperator 2020-10-30T03:00:12.816613+00:00 2020-10-30T03:00:15.742187+00:00 0:00:02.925574 4915 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2020-10-30T03:00:10.835041+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2020-10-30T01:00:00+00:00 EmrJobFlowSensor 2020-10-30T02:00:26.090003+00:00 2020-10-30T02:12:29.121054+00:00 0:12:03.031051 4913 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-10-30T02:00:24.335936+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2020-10-30T01:00:00+00:00 EmrCreateJobFlowOperator 2020-10-30T02:00:18.205704+00:00 2020-10-30T02:00:20.004622+00:00 0:00:01.798918 4912 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2020-10-30T02:00:16.334089+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2020-10-30T01:00:00+00:00 PythonOperator 2020-10-30T02:00:08.110174+00:00 2020-10-30T02:00:11.290027+00:00 0:00:03.179853 4911 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2020-10-30T02:00:06.335344+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2020-10-30T00:00:00+00:00 EmrJobFlowSensor 2020-10-30T01:00:26.781838+00:00 2020-10-30T01:12:29.945602+00:00 0:12:03.163764 4909 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-10-30T01:00:25.069075+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2020-10-30T00:00:00+00:00 EmrCreateJobFlowOperator 2020-10-30T01:00:18.908307+00:00 2020-10-30T01:00:20.684094+00:00 0:00:01.775787 4908 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2020-10-30T01:00:17.035109+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2020-10-30T00:00:00+00:00 PythonOperator 2020-10-30T01:00:08.954930+00:00 2020-10-30T01:00:11.953844+00:00 0:00:02.998914 4907 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2020-10-30T01:00:07.023292+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2020-10-29T23:00:00+00:00 EmrJobFlowSensor 2020-10-30T00:00:28.131091+00:00 2020-10-30T00:12:31.250594+00:00 0:12:03.119503 4905 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-10-30T00:00:26.415621+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2020-10-29T23:00:00+00:00 EmrCreateJobFlowOperator 2020-10-30T00:00:18.070095+00:00 2020-10-30T00:00:19.830556+00:00 0:00:01.760461 4904 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2020-10-30T00:00:16.404478+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2020-10-29T23:00:00+00:00 PythonOperator 2020-10-30T00:00:08.285707+00:00 2020-10-30T00:00:11.372854+00:00 0:00:03.087147 4903 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2020-10-30T00:00:06.404667+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2020-10-29T22:00:00+00:00 EmrJobFlowSensor 2020-10-29T23:00:29.168362+00:00 2020-10-29T23:12:32.201053+00:00 0:12:03.032691 4901 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-10-29T23:00:27.293577+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2020-10-28T23:00:00+00:00 EmrJobFlowSensor 2020-10-29T23:00:25.046447+00:00 2020-10-29T23:09:27.791420+00:00 0:09:02.744973 4900 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-10-29T23:00:23.293920+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2020-10-29T22:00:00+00:00 EmrCreateJobFlowOperator 2020-10-29T23:00:18.986295+00:00 2020-10-29T23:00:20.746990+00:00 0:00:01.760695 4899 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2020-10-29T23:00:17.283779+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2020-10-28T23:00:00+00:00 EmrCreateJobFlowOperator 2020-10-29T23:00:15.348892+00:00 2020-10-29T23:00:16.994555+00:00 0:00:01.645663 4898 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2020-10-29T23:00:13.290830+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2020-10-29T22:00:00+00:00 PythonOperator 2020-10-29T23:00:11.150315+00:00 2020-10-29T23:00:14.252814+00:00 0:00:03.102499 4897 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2020-10-29T23:00:09.279601+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2020-10-28T23:00:00+00:00 PythonOperator 2020-10-29T23:00:05.014847+00:00 2020-10-29T23:00:07.756383+00:00 0:00:02.741536 4896 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2020-10-29T23:00:03.271394+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2020-10-29T21:00:00+00:00 EmrJobFlowSensor 2020-10-29T22:00:31.742632+00:00 2020-10-29T22:12:34.924576+00:00 0:12:03.181944 4894 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-10-29T22:00:30.074634+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2020-10-29T21:00:00+00:00 EmrCreateJobFlowOperator 2020-10-29T22:00:21.823510+00:00 2020-10-29T22:00:23.563584+00:00 0:00:01.740074 4893 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2020-10-29T22:00:20.067995+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2020-10-29T21:00:00+00:00 PythonOperator 2020-10-29T22:00:11.858205+00:00 2020-10-29T22:00:14.738796+00:00 0:00:02.880591 4892 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2020-10-29T22:00:10.077538+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2020-10-29T20:00:00+00:00 EmrJobFlowSensor 2020-10-29T21:00:29.008907+00:00 2020-10-29T21:11:32.103872+00:00 0:11:03.094965 4890 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-10-29T21:00:27.211661+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2020-10-29T20:00:00+00:00 EmrCreateJobFlowOperator 2020-10-29T21:00:19.007971+00:00 2020-10-29T21:00:20.753814+00:00 0:00:01.745843 4889 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2020-10-29T21:00:17.202840+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2020-10-29T20:00:00+00:00 PythonOperator 2020-10-29T21:00:08.985769+00:00 2020-10-29T21:00:11.841296+00:00 0:00:02.855527 4888 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2020-10-29T21:00:07.194233+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2020-10-29T19:00:00+00:00 EmrJobFlowSensor 2020-10-29T20:00:29.739003+00:00 2020-10-29T20:12:33.003980+00:00 0:12:03.264977 4886 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-10-29T20:00:27.767225+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2020-10-29T19:00:00+00:00 EmrCreateJobFlowOperator 2020-10-29T20:00:19.840912+00:00 2020-10-29T20:00:21.610236+00:00 0:00:01.769324 4885 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2020-10-29T20:00:17.756459+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2020-10-29T19:00:00+00:00 PythonOperator 2020-10-29T20:00:11.699498+00:00 2020-10-29T20:00:14.599617+00:00 0:00:02.900119 4884 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2020-10-29T20:00:09.749667+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2020-10-29T18:00:00+00:00 EmrJobFlowSensor 2020-10-29T19:00:30.947346+00:00 2020-10-29T19:12:34.124088+00:00 0:12:03.176742 4882 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-10-29T19:00:29.043224+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2020-10-29T18:00:00+00:00 EmrCreateJobFlowOperator 2020-10-29T19:00:20.775795+00:00 2020-10-29T19:00:22.507474+00:00 0:00:01.731679 4881 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2020-10-29T19:00:19.039235+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2020-10-29T18:00:00+00:00 PythonOperator 2020-10-29T19:00:12.796664+00:00 2020-10-29T19:00:15.766322+00:00 0:00:02.969658 4880 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2020-10-29T19:00:11.028970+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2020-10-29T17:00:00+00:00 EmrJobFlowSensor 2020-10-29T18:00:29.260973+00:00 2020-10-29T18:12:32.414045+00:00 0:12:03.153072 4878 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-10-29T18:00:27.521130+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2020-10-29T17:00:00+00:00 EmrCreateJobFlowOperator 2020-10-29T18:00:19.381875+00:00 2020-10-29T18:00:21.077261+00:00 0:00:01.695386 4877 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2020-10-29T18:00:17.508314+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2020-10-29T17:00:00+00:00 PythonOperator 2020-10-29T18:00:09.251042+00:00 2020-10-29T18:00:12.123864+00:00 0:00:02.872822 4876 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2020-10-29T18:00:07.497860+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2020-10-29T16:00:00+00:00 EmrJobFlowSensor 2020-10-29T17:00:28.117460+00:00 2020-10-29T17:12:31.271604+00:00 0:12:03.154144 4874 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-10-29T17:00:26.354986+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2020-10-29T16:00:00+00:00 EmrCreateJobFlowOperator 2020-10-29T17:00:18.532957+00:00 2020-10-29T17:00:20.359264+00:00 0:00:01.826307 4873 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2020-10-29T17:00:16.373804+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2020-10-29T16:00:00+00:00 PythonOperator 2020-10-29T17:00:08.351475+00:00 2020-10-29T17:00:11.269713+00:00 0:00:02.918238 4872 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2020-10-29T17:00:06.351485+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2020-10-29T15:00:00+00:00 EmrJobFlowSensor 2020-10-29T16:00:32.087381+00:00 2020-10-29T16:12:35.228428+00:00 0:12:03.141047 4870 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-10-29T16:00:30.236195+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2020-10-29T15:00:00+00:00 EmrCreateJobFlowOperator 2020-10-29T16:00:22.089246+00:00 2020-10-29T16:00:23.942015+00:00 0:00:01.852769 4869 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2020-10-29T16:00:20.187422+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2020-10-29T15:00:00+00:00 PythonOperator 2020-10-29T16:00:12.465897+00:00 2020-10-29T16:00:15.409346+00:00 0:00:02.943449 4868 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2020-10-29T16:00:10.130007+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2020-10-29T14:00:00+00:00 EmrJobFlowSensor 2020-10-29T15:00:23.234496+00:00 2020-10-29T15:11:26.265313+00:00 0:11:03.030817 4866 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-10-29T15:00:21.309019+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2020-10-29T14:00:00+00:00 EmrCreateJobFlowOperator 2020-10-29T15:00:13.237294+00:00 2020-10-29T15:00:15.026689+00:00 0:00:01.789395 4865 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2020-10-29T15:00:11.325107+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2020-10-29T14:00:00+00:00 PythonOperator 2020-10-29T15:00:05.108155+00:00 2020-10-29T15:00:07.957052+00:00 0:00:02.848897 4864 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2020-10-29T15:00:03.314481+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2020-10-29T13:00:00+00:00 EmrJobFlowSensor 2020-10-29T14:00:30.554830+00:00 2020-10-29T14:12:33.829069+00:00 0:12:03.274239 4862 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-10-29T14:00:28.263062+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2020-10-29T13:00:00+00:00 EmrCreateJobFlowOperator 2020-10-29T14:00:20.036588+00:00 2020-10-29T14:00:21.801859+00:00 0:00:01.765271 4861 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2020-10-29T14:00:18.211999+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2020-10-29T13:00:00+00:00 PythonOperator 2020-10-29T14:00:10.769106+00:00 2020-10-29T14:00:13.829702+00:00 0:00:03.060596 4860 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2020-10-29T14:00:08.272431+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2020-10-29T12:00:00+00:00 EmrJobFlowSensor 2020-10-29T13:00:27.477008+00:00 2020-10-29T13:12:30.591965+00:00 0:12:03.114957 4858 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-10-29T13:00:25.595068+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2020-10-29T12:00:00+00:00 EmrCreateJobFlowOperator 2020-10-29T13:00:17.243151+00:00 2020-10-29T13:00:19.028101+00:00 0:00:01.784950 4857 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2020-10-29T13:00:15.581972+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2020-10-29T12:00:00+00:00 PythonOperator 2020-10-29T13:00:09.281743+00:00 2020-10-29T13:00:12.213019+00:00 0:00:02.931276 4856 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2020-10-29T13:00:07.578845+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2020-10-29T11:00:00+00:00 EmrJobFlowSensor 2020-10-29T12:00:26.857923+00:00 2020-10-29T12:12:29.968700+00:00 0:12:03.110777 4854 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-10-29T12:00:25.113505+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2020-10-29T11:00:00+00:00 EmrCreateJobFlowOperator 2020-10-29T12:00:18.836266+00:00 2020-10-29T12:00:20.556737+00:00 0:00:01.720471 4853 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2020-10-29T12:00:17.089016+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2020-10-29T11:00:00+00:00 PythonOperator 2020-10-29T12:00:08.822640+00:00 2020-10-29T12:00:11.672947+00:00 0:00:02.850307 4852 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2020-10-29T12:00:07.080043+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2020-10-29T10:00:00+00:00 EmrJobFlowSensor 2020-10-29T11:00:30.788296+00:00 2020-10-29T11:12:33.980747+00:00 0:12:03.192451 4850 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-10-29T11:00:28.428826+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2020-10-29T10:00:00+00:00 EmrCreateJobFlowOperator 2020-10-29T11:00:20.318478+00:00 2020-10-29T11:00:21.992177+00:00 0:00:01.673699 4849 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2020-10-29T11:00:18.417146+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2020-10-29T10:00:00+00:00 PythonOperator 2020-10-29T11:00:12.349734+00:00 2020-10-29T11:00:15.229754+00:00 0:00:02.880020 4848 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2020-10-29T11:00:10.401936+00:00 2 default_pool
success 24hrPOP-Aggregator-ModelTransform_v002 check_cluster_status 2020-10-29T04:48:14.575748+00:00 EmrJobFlowSensor 2020-10-29T10:17:22.257621+00:00 4846 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-10-29T10:17:20.587411+00:00 4 default_pool
success 24hrPOP-Aggregator-ModelTransform_v002 create_cluster_and_add_emr_steps 2020-10-29T04:48:14.575748+00:00 EmrCreateJobFlowOperator 2020-10-29T10:17:12.279426+00:00 2020-10-29T10:17:13.998413+00:00 0:00:01.718987 4845 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2020-10-29T10:17:10.589634+00:00 3 default_pool
success 24hrPOP-Aggregator-ModelTransform_v002 create_emr_steps 2020-10-29T04:48:14.575748+00:00 PythonOperator 2020-10-29T10:17:04.213215+00:00 2020-10-29T10:17:06.901085+00:00 0:00:02.687870 4844 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2020-10-29T10:17:02.568750+00:00 4 default_pool
success booking-processing-job_v002 check_cluster_status 2020-10-29T09:00:00+00:00 EmrJobFlowSensor 2020-10-29T10:00:23.570793+00:00 2020-10-29T10:12:26.755036+00:00 0:12:03.184243 4841 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-10-29T10:00:21.658831+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2020-10-29T09:00:00+00:00 EmrCreateJobFlowOperator 2020-10-29T10:00:13.499706+00:00 2020-10-29T10:00:15.283164+00:00 0:00:01.783458 4840 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2020-10-29T10:00:11.664418+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2020-10-29T09:00:00+00:00 PythonOperator 2020-10-29T10:00:03.414350+00:00 2020-10-29T10:00:06.366073+00:00 0:00:02.951723 4839 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2020-10-29T10:00:01.639706+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2020-10-29T08:00:00+00:00 EmrJobFlowSensor 2020-10-29T09:20:59.666461+00:00 2020-10-29T09:33:02.909928+00:00 0:12:03.243467 4837 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-10-29T09:20:57.793821+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2020-10-29T08:00:00+00:00 EmrCreateJobFlowOperator 2020-10-29T09:20:49.735403+00:00 2020-10-29T09:20:51.464748+00:00 0:00:01.729345 4836 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2020-10-29T09:20:47.785509+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2020-10-29T08:00:00+00:00 PythonOperator 2020-10-29T09:20:39.654101+00:00 2020-10-29T09:20:42.607347+00:00 0:00:02.953246 4835 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2020-10-29T09:20:37.767724+00:00 2 default_pool
success missing-dr-check-job_v002 check_cluster_status 2020-10-28T07:30:00+00:00 EmrJobFlowSensor 2020-10-29T07:30:29.832497+00:00 2020-10-29T07:39:32.457524+00:00 0:09:02.625027 4832 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-10-29T07:30:27.982469+00:00 2 default_pool
success daily-import-job_v002 check_cluster_status 2020-10-28T07:30:00+00:00 EmrJobFlowSensor 2020-10-29T07:30:25.635905+00:00 2020-10-29T07:39:28.234508+00:00 0:09:02.598603 4831 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-10-29T07:30:23.988897+00:00 2 default_pool
success missing-dr-check-job_v002 create_cluster_and_add_emr_steps 2020-10-28T07:30:00+00:00 EmrCreateJobFlowOperator 2020-10-29T07:30:20.049498+00:00 2020-10-29T07:30:21.768027+00:00 0:00:01.718529 4830 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2020-10-29T07:30:17.969102+00:00 2 default_pool
success daily-import-job_v002 create_cluster_and_add_emr_steps 2020-10-28T07:30:00+00:00 EmrCreateJobFlowOperator 2020-10-29T07:30:15.774893+00:00 2020-10-29T07:30:17.469080+00:00 0:00:01.694187 4829 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2020-10-29T07:30:13.984836+00:00 2 default_pool
success missing-dr-check-job_v002 create_emr_steps 2020-10-28T07:30:00+00:00 PythonOperator 2020-10-29T07:30:09.965390+00:00 2020-10-29T07:30:12.630683+00:00 0:00:02.665293 4828 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2020-10-29T07:30:07.961246+00:00 2 default_pool
success daily-import-job_v002 create_emr_steps 2020-10-28T07:30:00+00:00 PythonOperator 2020-10-29T07:30:05.700353+00:00 2020-10-29T07:30:08.551754+00:00 0:00:02.851401 4827 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2020-10-29T07:30:03.966712+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2020-10-29T06:00:00+00:00 EmrJobFlowSensor 2020-10-29T07:00:50.429957+00:00 2020-10-29T07:12:53.408458+00:00 0:12:02.978501 4826 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-10-29T07:00:48.305771+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2020-10-29T06:00:00+00:00 EmrCreateJobFlowOperator 2020-10-29T07:00:30.377833+00:00 2020-10-29T07:00:32.107123+00:00 0:00:01.729290 4825 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2020-10-29T07:00:28.289434+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2020-10-29T06:00:00+00:00 PythonOperator 2020-10-29T07:00:12.158290+00:00 2020-10-29T07:00:14.968082+00:00 0:00:02.809792 4824 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2020-10-29T07:00:10.271311+00:00 2 default_pool