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

Reset Filters
  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 create_cluster_and_add_emr_steps 2023-05-14T22:00:00+00:00 EmrCreateJobFlowOperator 2023-05-14T23:01:00.516969+00:00 2023-05-14T23:01:01.252865+00:00 0:00:00.735896 379274 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-14T23:00:58.227157+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-14T22:00:00+00:00 PythonOperator 2023-05-14T23:00:38.360939+00:00 2023-05-14T23:00:40.576878+00:00 0:00:02.215939 379271 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-14T23:00:36.207481+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-14T21:00:00+00:00 TriggerDagRunOperator 2023-05-14T22:11:12.405189+00:00 2023-05-14T22:11:12.855310+00:00 0:00:00.450121 379255 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-14T22:11:09.915065+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-14T21:00:00+00:00 TriggerDagRunOperator 2023-05-14T22:11:12.306322+00:00 2023-05-14T22:11:12.696906+00:00 0:00:00.390584 379254 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-14T22:11:09.915035+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-14T21:00:00+00:00 EmrJobFlowSensor 2023-05-14T22:00:48.320065+00:00 2023-05-14T22:10:50.112353+00:00 0:10:01.792288 379246 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-14T22:00:46.185834+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-14T21:00:00+00:00 EmrCreateJobFlowOperator 2023-05-14T22:00:28.840432+00:00 2023-05-14T22:00:29.768194+00:00 0:00:00.927762 379244 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-14T22:00:26.170952+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-14T21:00:00+00:00 PythonOperator 2023-05-14T22:00:04.949763+00:00 2023-05-14T22:00:05.988427+00:00 0:00:01.038664 379242 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-14T22:00:02.110381+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-14T20:00:00+00:00 TriggerDagRunOperator 2023-05-14T21:10:39.492668+00:00 2023-05-14T21:10:39.823112+00:00 0:00:00.330444 379227 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-14T21:10:36.974693+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-14T20:00:00+00:00 TriggerDagRunOperator 2023-05-14T21:10:39.472114+00:00 2023-05-14T21:10:39.935665+00:00 0:00:00.463551 379226 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-14T21:10:36.974722+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-14T20:00:00+00:00 EmrJobFlowSensor 2023-05-14T21:01:24.284454+00:00 2023-05-14T21:10:26.065413+00:00 0:09:01.780959 379220 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-14T21:01:21.909941+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-14T20:00:00+00:00 EmrCreateJobFlowOperator 2023-05-14T21:01:04.161183+00:00 2023-05-14T21:01:05.079658+00:00 0:00:00.918475 379218 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-14T21:01:01.879466+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-14T20:00:00+00:00 PythonOperator 2023-05-14T21:00:42.026670+00:00 2023-05-14T21:00:43.047429+00:00 0:00:01.020759 379216 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-14T21:00:39.856715+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-14T19:00:00+00:00 TriggerDagRunOperator 2023-05-14T20:11:43.662749+00:00 2023-05-14T20:11:44.115060+00:00 0:00:00.452311 379200 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-14T20:11:41.046239+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-14T19:00:00+00:00 TriggerDagRunOperator 2023-05-14T20:11:43.575128+00:00 2023-05-14T20:11:43.946032+00:00 0:00:00.370904 379199 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-14T20:11:41.046211+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-14T19:00:00+00:00 EmrJobFlowSensor 2023-05-14T20:01:21.172723+00:00 2023-05-14T20:11:23.100178+00:00 0:10:01.927455 379192 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-14T20:01:18.892344+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-14T19:00:00+00:00 EmrCreateJobFlowOperator 2023-05-14T20:01:01.116654+00:00 2023-05-14T20:01:02.123400+00:00 0:00:01.006746 379190 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-14T20:00:58.840647+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-14T19:00:00+00:00 PythonOperator 2023-05-14T20:00:39.624904+00:00 2023-05-14T20:00:40.611662+00:00 0:00:00.986758 379188 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-14T20:00:36.820311+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-14T18:00:00+00:00 TriggerDagRunOperator 2023-05-14T19:11:40.899318+00:00 2023-05-14T19:11:41.325295+00:00 0:00:00.425977 379170 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-14T19:11:38.397474+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-14T18:00:00+00:00 TriggerDagRunOperator 2023-05-14T19:11:40.804296+00:00 2023-05-14T19:11:41.152112+00:00 0:00:00.347816 379169 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-14T19:11:38.397523+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-14T18:00:00+00:00 EmrJobFlowSensor 2023-05-14T19:01:23.796744+00:00 2023-05-14T19:11:25.564243+00:00 0:10:01.767499 379162 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-14T19:01:21.610271+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-14T18:00:00+00:00 EmrCreateJobFlowOperator 2023-05-14T19:01:01.725583+00:00 2023-05-14T19:01:02.687586+00:00 0:00:00.962003 379161 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-14T19:00:59.532828+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-14T18:00:00+00:00 PythonOperator 2023-05-14T19:00:41.625067+00:00 2023-05-14T19:00:42.610857+00:00 0:00:00.985790 379160 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-14T19:00:39.515590+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-14T17:00:00+00:00 TriggerDagRunOperator 2023-05-14T18:11:22.951471+00:00 2023-05-14T18:11:23.415602+00:00 0:00:00.464131 379143 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-14T18:11:20.413095+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-14T17:00:00+00:00 TriggerDagRunOperator 2023-05-14T18:11:22.718805+00:00 2023-05-14T18:11:23.050769+00:00 0:00:00.331964 379142 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-14T18:11:20.413048+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-14T17:00:00+00:00 EmrJobFlowSensor 2023-05-14T18:01:01.007439+00:00 2023-05-14T18:11:02.861572+00:00 0:10:01.854133 379135 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-14T18:00:58.804619+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-14T17:00:00+00:00 EmrCreateJobFlowOperator 2023-05-14T18:00:41.221628+00:00 2023-05-14T18:00:42.053200+00:00 0:00:00.831572 379134 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-14T18:00:38.787476+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-14T17:00:00+00:00 PythonOperator 2023-05-14T18:00:19.099881+00:00 2023-05-14T18:00:20.123238+00:00 0:00:01.023357 379133 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-14T18:00:16.730095+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-14T16:00:00+00:00 TriggerDagRunOperator 2023-05-14T17:11:21.259726+00:00 2023-05-14T17:11:21.718477+00:00 0:00:00.458751 379118 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-14T17:11:18.685072+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-14T16:00:00+00:00 TriggerDagRunOperator 2023-05-14T17:11:21.200760+00:00 2023-05-14T17:11:21.563249+00:00 0:00:00.362489 379117 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-14T17:11:18.685043+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-14T16:00:00+00:00 EmrJobFlowSensor 2023-05-14T17:01:02.177173+00:00 2023-05-14T17:11:03.978156+00:00 0:10:01.800983 379110 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-14T17:00:59.946187+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-14T16:00:00+00:00 EmrCreateJobFlowOperator 2023-05-14T17:00:40.313856+00:00 2023-05-14T17:00:41.123115+00:00 0:00:00.809259 379108 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-14T17:00:37.930932+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-14T16:00:00+00:00 PythonOperator 2023-05-14T17:00:20.143807+00:00 2023-05-14T17:00:21.202378+00:00 0:00:01.058571 379106 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-14T17:00:17.824928+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-14T15:00:00+00:00 TriggerDagRunOperator 2023-05-14T16:12:28.706012+00:00 2023-05-14T16:12:29.165083+00:00 0:00:00.459071 379092 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-14T16:12:26.106160+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-14T15:00:00+00:00 TriggerDagRunOperator 2023-05-14T16:12:28.408024+00:00 2023-05-14T16:12:28.759421+00:00 0:00:00.351397 379091 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-14T16:12:26.106189+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-14T15:00:00+00:00 EmrJobFlowSensor 2023-05-14T16:01:17.161208+00:00 2023-05-14T16:12:19.182110+00:00 0:11:02.020902 379084 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-14T16:01:14.897018+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-14T15:00:00+00:00 EmrCreateJobFlowOperator 2023-05-14T16:00:57.370351+00:00 2023-05-14T16:00:58.272768+00:00 0:00:00.902417 379082 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-14T16:00:54.898082+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-14T15:00:00+00:00 PythonOperator 2023-05-14T16:00:36.001541+00:00 2023-05-14T16:00:36.994191+00:00 0:00:00.992650 379080 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-14T16:00:32.832629+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-14T14:00:00+00:00 TriggerDagRunOperator 2023-05-14T15:12:21.034013+00:00 2023-05-14T15:12:21.368409+00:00 0:00:00.334396 379070 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-14T15:12:18.632531+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-14T14:00:00+00:00 TriggerDagRunOperator 2023-05-14T15:12:21.025602+00:00 2023-05-14T15:12:21.481592+00:00 0:00:00.455990 379069 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-14T15:12:18.632503+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-14T14:00:00+00:00 EmrJobFlowSensor 2023-05-14T15:01:55.737908+00:00 2023-05-14T15:11:57.501980+00:00 0:10:01.764072 379062 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-14T15:01:53.415023+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-14T14:00:00+00:00 EmrCreateJobFlowOperator 2023-05-14T15:01:33.551198+00:00 2023-05-14T15:01:34.382466+00:00 0:00:00.831268 379060 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-14T15:01:31.372707+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-14T14:00:00+00:00 PythonOperator 2023-05-14T15:01:13.631287+00:00 2023-05-14T15:01:14.684143+00:00 0:00:01.052856 379058 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-14T15:01:11.355227+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-14T13:00:00+00:00 TriggerDagRunOperator 2023-05-14T14:25:32.627014+00:00 2023-05-14T14:25:33.073553+00:00 0:00:00.446539 379047 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-14T14:25:29.316005+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-14T13:00:00+00:00 TriggerDagRunOperator 2023-05-14T14:25:32.412028+00:00 2023-05-14T14:25:32.754799+00:00 0:00:00.342771 379046 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-14T14:25:29.315955+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-14T13:00:00+00:00 EmrJobFlowSensor 2023-05-14T14:06:57.343380+00:00 2023-05-14T14:16:59.133334+00:00 0:10:01.789954 379042 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-14T14:06:54.613687+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-14T13:00:00+00:00 EmrCreateJobFlowOperator 2023-05-14T14:06:36.725388+00:00 2023-05-14T14:06:37.534521+00:00 0:00:00.809133 379039 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-14T14:06:34.571337+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-14T13:00:00+00:00 PythonOperator 2023-05-14T14:06:15.091902+00:00 2023-05-14T14:06:16.175797+00:00 0:00:01.083895 379036 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-14T14:06:12.558160+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-14T12:00:00+00:00 TriggerDagRunOperator 2023-05-14T13:21:18.281461+00:00 2023-05-14T13:21:18.825867+00:00 0:00:00.544406 379024 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-14T13:21:15.482380+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-14T12:00:00+00:00 TriggerDagRunOperator 2023-05-14T13:21:18.138346+00:00 2023-05-14T13:21:18.658007+00:00 0:00:00.519661 379023 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-14T13:21:15.482342+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-14T12:00:00+00:00 EmrJobFlowSensor 2023-05-14T13:11:01.016736+00:00 2023-05-14T13:21:03.003814+00:00 0:10:01.987078 379018 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-14T13:10:58.717989+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-14T12:00:00+00:00 EmrCreateJobFlowOperator 2023-05-14T13:10:38.819621+00:00 2023-05-14T13:10:39.707718+00:00 0:00:00.888097 379015 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-14T13:10:36.672639+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-14T12:00:00+00:00 PythonOperator 2023-05-14T13:10:19.514123+00:00 2023-05-14T13:10:20.537062+00:00 0:00:01.022939 379012 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-14T13:10:16.698701+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-14T11:00:00+00:00 TriggerDagRunOperator 2023-05-14T12:16:36.094838+00:00 2023-05-14T12:16:36.565939+00:00 0:00:00.471101 379002 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-14T12:16:33.505140+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-14T11:00:00+00:00 TriggerDagRunOperator 2023-05-14T12:16:36.000759+00:00 2023-05-14T12:16:36.348864+00:00 0:00:00.348105 379001 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-14T12:16:33.505111+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-14T11:00:00+00:00 EmrJobFlowSensor 2023-05-14T12:01:04.282236+00:00 2023-05-14T12:11:06.031828+00:00 0:10:01.749592 378991 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-14T12:01:01.987885+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-14T11:00:00+00:00 EmrCreateJobFlowOperator 2023-05-14T12:00:42.013473+00:00 2023-05-14T12:00:42.871021+00:00 0:00:00.857548 378990 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-14T12:00:39.907575+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-14T11:00:00+00:00 PythonOperator 2023-05-14T12:00:21.937492+00:00 2023-05-14T12:00:22.989721+00:00 0:00:01.052229 378989 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-14T12:00:19.848293+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-14T10:00:00+00:00 TriggerDagRunOperator 2023-05-14T11:11:19.439742+00:00 2023-05-14T11:11:19.903387+00:00 0:00:00.463645 378976 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-14T11:11:17.099281+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-14T10:00:00+00:00 TriggerDagRunOperator 2023-05-14T11:11:19.372686+00:00 2023-05-14T11:11:19.706889+00:00 0:00:00.334203 378975 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-14T11:11:17.099320+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-14T10:00:00+00:00 EmrJobFlowSensor 2023-05-14T11:00:54.477473+00:00 2023-05-14T11:10:56.427727+00:00 0:10:01.950254 378968 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-14T11:00:52.163317+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-14T10:00:00+00:00 EmrCreateJobFlowOperator 2023-05-14T11:00:34.397340+00:00 2023-05-14T11:00:35.305405+00:00 0:00:00.908065 378966 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-14T11:00:32.142295+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-14T10:00:00+00:00 PythonOperator 2023-05-14T11:00:12.597298+00:00 2023-05-14T11:00:13.642015+00:00 0:00:01.044717 378964 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-14T11:00:10.125609+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-14T09:00:00+00:00 TriggerDagRunOperator 2023-05-14T10:16:30.461386+00:00 2023-05-14T10:16:30.851266+00:00 0:00:00.389880 378953 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-14T10:16:27.715538+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-14T09:00:00+00:00 TriggerDagRunOperator 2023-05-14T10:16:30.302270+00:00 2023-05-14T10:16:30.774742+00:00 0:00:00.472472 378952 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-14T10:16:27.715570+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-14T09:00:00+00:00 EmrJobFlowSensor 2023-05-14T10:06:10.819787+00:00 2023-05-14T10:16:12.602741+00:00 0:10:01.782954 378948 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-14T10:06:08.027818+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-14T09:00:00+00:00 EmrCreateJobFlowOperator 2023-05-14T10:05:50.167473+00:00 2023-05-14T10:05:51.126241+00:00 0:00:00.958768 378945 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-14T10:05:48.010105+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-14T09:00:00+00:00 PythonOperator 2023-05-14T10:05:29.006400+00:00 2023-05-14T10:05:30.274964+00:00 0:00:01.268564 378942 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-14T10:05:26.015530+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-14T08:00:00+00:00 TriggerDagRunOperator 2023-05-14T09:11:11.744349+00:00 2023-05-14T09:11:12.201080+00:00 0:00:00.456731 378929 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-14T09:11:08.909473+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-14T08:00:00+00:00 TriggerDagRunOperator 2023-05-14T09:11:11.615176+00:00 2023-05-14T09:11:11.957301+00:00 0:00:00.342125 378928 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-14T09:11:08.909502+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-14T08:00:00+00:00 EmrJobFlowSensor 2023-05-14T09:00:47.371448+00:00 2023-05-14T09:10:49.364230+00:00 0:10:01.992782 378921 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-14T09:00:45.088867+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-14T08:00:00+00:00 EmrCreateJobFlowOperator 2023-05-14T09:00:25.199024+00:00 2023-05-14T09:00:26.040660+00:00 0:00:00.841636 378919 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-14T09:00:22.935388+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-14T08:00:00+00:00 PythonOperator 2023-05-14T09:00:05.241974+00:00 2023-05-14T09:00:06.272871+00:00 0:00:01.030897 378917 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-14T09:00:02.914100+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-14T07:00:00+00:00 TriggerDagRunOperator 2023-05-14T08:12:14.130719+00:00 2023-05-14T08:12:14.633860+00:00 0:00:00.503141 378904 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-14T08:12:11.794728+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-14T07:00:00+00:00 TriggerDagRunOperator 2023-05-14T08:12:13.986738+00:00 2023-05-14T08:12:14.331244+00:00 0:00:00.344506 378903 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-14T08:12:11.794697+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-14T07:00:00+00:00 EmrJobFlowSensor 2023-05-14T08:01:07.600946+00:00 2023-05-14T08:11:09.376526+00:00 0:10:01.775580 378899 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-14T08:01:05.444967+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-14T07:00:00+00:00 EmrCreateJobFlowOperator 2023-05-14T08:00:45.712053+00:00 2023-05-14T08:00:46.615001+00:00 0:00:00.902948 378897 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-14T08:00:43.431069+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-14T07:00:00+00:00 PythonOperator 2023-05-14T08:00:23.855329+00:00 2023-05-14T08:00:24.934504+00:00 0:00:01.079175 378895 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-14T08:00:21.413868+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-14T06:00:00+00:00 TriggerDagRunOperator 2023-05-14T07:15:53.332767+00:00 2023-05-14T07:15:53.922967+00:00 0:00:00.590200 378883 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-14T07:15:50.180275+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-14T06:00:00+00:00 TriggerDagRunOperator 2023-05-14T07:15:53.161205+00:00 2023-05-14T07:15:53.543112+00:00 0:00:00.381907 378882 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-14T07:15:50.180246+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-14T06:00:00+00:00 EmrJobFlowSensor 2023-05-14T07:05:34.565357+00:00 2023-05-14T07:15:36.393609+00:00 0:10:01.828252 378876 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-14T07:05:32.445013+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-14T06:00:00+00:00 EmrCreateJobFlowOperator 2023-05-14T07:05:12.749543+00:00 2023-05-14T07:05:13.676602+00:00 0:00:00.927059 378873 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-14T07:05:10.425249+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-14T06:00:00+00:00 PythonOperator 2023-05-14T07:04:52.916973+00:00 2023-05-14T07:04:53.979129+00:00 0:00:01.062156 378871 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-14T07:04:50.411889+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-14T05:00:00+00:00 TriggerDagRunOperator 2023-05-14T06:11:54.866524+00:00 2023-05-14T06:11:55.356465+00:00 0:00:00.489941 378858 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-14T06:11:52.003479+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-14T05:00:00+00:00 TriggerDagRunOperator 2023-05-14T06:11:54.651288+00:00 2023-05-14T06:11:55.116851+00:00 0:00:00.465563 378857 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-14T06:11:52.003518+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-14T05:00:00+00:00 EmrJobFlowSensor 2023-05-14T06:01:37.165958+00:00 2023-05-14T06:11:39.107795+00:00 0:10:01.941837 378851 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-14T06:01:34.906239+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-14T05:00:00+00:00 EmrCreateJobFlowOperator 2023-05-14T06:01:17.194722+00:00 2023-05-14T06:01:18.141779+00:00 0:00:00.947057 378849 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-14T06:01:14.839729+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-14T05:00:00+00:00 PythonOperator 2023-05-14T06:00:55.520152+00:00 2023-05-14T06:00:56.789819+00:00 0:00:01.269667 378847 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-14T06:00:52.824002+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-14T04:00:00+00:00 TriggerDagRunOperator 2023-05-14T05:15:29.247616+00:00 2023-05-14T05:15:29.733879+00:00 0:00:00.486263 378833 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-14T05:15:26.784198+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-14T04:00:00+00:00 TriggerDagRunOperator 2023-05-14T05:15:29.160298+00:00 2023-05-14T05:15:29.502921+00:00 0:00:00.342623 378832 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-14T05:15:26.784228+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-14T04:00:00+00:00 EmrJobFlowSensor 2023-05-14T05:03:04.150817+00:00 2023-05-14T05:13:05.965192+00:00 0:10:01.814375 378825 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-14T05:03:02.023534+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-14T04:00:00+00:00 EmrCreateJobFlowOperator 2023-05-14T05:02:44.158185+00:00 2023-05-14T05:02:45.128859+00:00 0:00:00.970674 378823 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-14T05:02:42.005454+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-14T04:00:00+00:00 PythonOperator 2023-05-14T05:02:22.423474+00:00 2023-05-14T05:02:23.469113+00:00 0:00:01.045639 378821 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-14T05:02:20.020544+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-14T03:00:00+00:00 TriggerDagRunOperator 2023-05-14T04:24:37.283804+00:00 2023-05-14T04:24:37.723523+00:00 0:00:00.439719 378811 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-14T04:24:34.114708+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-14T03:00:00+00:00 TriggerDagRunOperator 2023-05-14T04:24:37.102470+00:00 2023-05-14T04:24:37.453720+00:00 0:00:00.351250 378810 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-14T04:24:34.114757+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-14T03:00:00+00:00 EmrJobFlowSensor 2023-05-14T04:01:35.792308+00:00 2023-05-14T04:10:37.491289+00:00 0:09:01.698981 378804 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-14T04:01:33.423097+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-14T03:00:00+00:00 EmrCreateJobFlowOperator 2023-05-14T04:00:34.591916+00:00 2023-05-14T04:00:35.382552+00:00 0:00:00.790636 378801 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-14T04:00:32.287470+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-14T03:00:00+00:00 PythonOperator 2023-05-14T04:00:12.327081+00:00 2023-05-14T04:00:13.371138+00:00 0:00:01.044057 378799 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-14T04:00:10.208447+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-14T02:00:00+00:00 TriggerDagRunOperator 2023-05-14T03:14:50.829482+00:00 2023-05-14T03:14:51.286117+00:00 0:00:00.456635 378788 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-14T03:14:47.711500+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-14T02:00:00+00:00 TriggerDagRunOperator 2023-05-14T03:14:50.691623+00:00 2023-05-14T03:14:51.047138+00:00 0:00:00.355515 378787 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-14T03:14:47.711458+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-14T02:00:00+00:00 EmrJobFlowSensor 2023-05-14T03:04:40.468043+00:00 2023-05-14T03:14:42.432359+00:00 0:10:01.964316 378781 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-14T03:04:38.003466+00:00 2 default_pool