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-06-03T02:00:00+00:00 EmrCreateJobFlowOperator 2023-06-03T03:12:20.624122+00:00 2023-06-03T03:12:21.633131+00:00 0:00:01.009009 390235 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-03T03:12:18.504296+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-03T02:00:00+00:00 PythonOperator 2023-06-03T03:11:58.520663+00:00 2023-06-03T03:11:59.452092+00:00 0:00:00.931429 390232 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-03T03:11:56.482593+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-03T01:00:00+00:00 TriggerDagRunOperator 2023-06-03T02:11:18.041547+00:00 2023-06-03T02:11:18.485694+00:00 0:00:00.444147 390222 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-03T02:11:15.894667+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-03T01:00:00+00:00 TriggerDagRunOperator 2023-06-03T02:11:17.878495+00:00 2023-06-03T02:11:18.323233+00:00 0:00:00.444738 390221 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-03T02:11:15.894634+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-03T01:00:00+00:00 EmrJobFlowSensor 2023-06-03T02:01:00.874670+00:00 2023-06-03T02:11:02.957628+00:00 0:10:02.082958 390215 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-03T02:00:58.786743+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-03T01:00:00+00:00 EmrCreateJobFlowOperator 2023-06-03T02:00:38.796312+00:00 2023-06-03T02:00:39.755927+00:00 0:00:00.959615 390213 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-03T02:00:36.766377+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-03T01:00:00+00:00 PythonOperator 2023-06-03T02:00:16.699858+00:00 2023-06-03T02:00:17.725322+00:00 0:00:01.025464 390211 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-03T02:00:14.744932+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-03T00:00:00+00:00 TriggerDagRunOperator 2023-06-03T01:18:05.457461+00:00 2023-06-03T01:18:05.883097+00:00 0:00:00.425636 390190 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-03T01:18:02.873885+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-03T00:00:00+00:00 TriggerDagRunOperator 2023-06-03T01:18:05.297114+00:00 2023-06-03T01:18:05.698351+00:00 0:00:00.401237 390189 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-03T01:18:02.873915+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-03T00:00:00+00:00 EmrJobFlowSensor 2023-06-03T01:06:38.983946+00:00 2023-06-03T01:17:41.095694+00:00 0:11:02.111748 390186 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-03T01:06:36.908286+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-03T00:00:00+00:00 EmrCreateJobFlowOperator 2023-06-03T01:06:17.000352+00:00 2023-06-03T01:06:18.077294+00:00 0:00:01.076942 390183 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-03T01:06:14.884204+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-03T00:00:00+00:00 PythonOperator 2023-06-03T01:05:54.821504+00:00 2023-06-03T01:05:55.778642+00:00 0:00:00.957138 390179 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-03T01:05:52.866222+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-02T23:00:00+00:00 TriggerDagRunOperator 2023-06-03T00:11:19.049761+00:00 2023-06-03T00:11:19.473570+00:00 0:00:00.423809 390168 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-03T00:11:16.755353+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-02T23:00:00+00:00 TriggerDagRunOperator 2023-06-03T00:11:19.049871+00:00 2023-06-03T00:11:19.487501+00:00 0:00:00.437630 390167 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-03T00:11:16.755325+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-02T23:00:00+00:00 EmrJobFlowSensor 2023-06-03T00:00:59.955385+00:00 2023-06-03T00:11:01.812908+00:00 0:10:01.857523 390159 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-03T00:00:57.802444+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-02T23:00:00+00:00 EmrCreateJobFlowOperator 2023-06-03T00:00:39.738645+00:00 2023-06-03T00:00:40.636295+00:00 0:00:00.897650 390157 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-03T00:00:37.742836+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-02T23:00:00+00:00 PythonOperator 2023-06-03T00:00:17.820145+00:00 2023-06-03T00:00:19.195107+00:00 0:00:01.374962 390155 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-03T00:00:15.721224+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-02T22:00:00+00:00 TriggerDagRunOperator 2023-06-02T23:11:16.839326+00:00 2023-06-02T23:11:17.308585+00:00 0:00:00.469259 390145 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-02T23:11:14.292022+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-02T22:00:00+00:00 TriggerDagRunOperator 2023-06-02T23:11:16.804057+00:00 2023-06-02T23:11:17.200280+00:00 0:00:00.396223 390144 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-02T23:11:14.291995+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-02T22:00:00+00:00 EmrJobFlowSensor 2023-06-02T23:00:57.748946+00:00 2023-06-02T23:10:59.524965+00:00 0:10:01.776019 390137 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-02T23:00:55.728285+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-02T22:00:00+00:00 EmrCreateJobFlowOperator 2023-06-02T23:00:37.718198+00:00 2023-06-02T23:00:38.582141+00:00 0:00:00.863943 390134 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-02T23:00:35.715633+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-02T22:00:00+00:00 PythonOperator 2023-06-02T23:00:15.613448+00:00 2023-06-02T23:00:16.571297+00:00 0:00:00.957849 390131 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-02T23:00:13.673146+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-02T21:00:00+00:00 TriggerDagRunOperator 2023-06-02T22:11:14.235351+00:00 2023-06-02T22:11:14.681640+00:00 0:00:00.446289 390119 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-02T22:11:12.005770+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-02T21:00:00+00:00 TriggerDagRunOperator 2023-06-02T22:11:14.215655+00:00 2023-06-02T22:11:14.642520+00:00 0:00:00.426865 390118 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-02T22:11:12.005800+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-02T21:00:00+00:00 EmrJobFlowSensor 2023-06-02T22:00:59.307681+00:00 2023-06-02T22:11:00.979379+00:00 0:10:01.671698 390111 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-02T22:00:57.102552+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-02T21:00:00+00:00 EmrCreateJobFlowOperator 2023-06-02T22:00:37.207498+00:00 2023-06-02T22:00:38.199729+00:00 0:00:00.992231 390109 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-02T22:00:35.093447+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-02T21:00:00+00:00 PythonOperator 2023-06-02T22:00:15.113563+00:00 2023-06-02T22:00:16.089085+00:00 0:00:00.975522 390107 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-02T22:00:13.010919+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-02T20:00:00+00:00 TriggerDagRunOperator 2023-06-02T21:11:45.172135+00:00 2023-06-02T21:11:45.665177+00:00 0:00:00.493042 390096 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-02T21:11:42.796282+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-02T20:00:00+00:00 TriggerDagRunOperator 2023-06-02T21:11:45.123550+00:00 2023-06-02T21:11:45.611677+00:00 0:00:00.488127 390095 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-02T21:11:42.796310+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-02T20:00:00+00:00 EmrJobFlowSensor 2023-06-02T21:01:31.939784+00:00 2023-06-02T21:11:33.855339+00:00 0:10:01.915555 390089 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-02T21:01:29.492706+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-02T20:00:00+00:00 EmrCreateJobFlowOperator 2023-06-02T21:00:46.455051+00:00 2023-06-02T21:00:47.344821+00:00 0:00:00.889770 390086 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-02T21:00:44.406551+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-02T20:00:00+00:00 PythonOperator 2023-06-02T21:00:24.371685+00:00 2023-06-02T21:00:25.257471+00:00 0:00:00.885786 390084 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-02T21:00:22.359886+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-02T19:00:00+00:00 TriggerDagRunOperator 2023-06-02T20:11:10.830171+00:00 2023-06-02T20:11:11.335803+00:00 0:00:00.505632 390073 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-02T20:11:08.296138+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-02T19:00:00+00:00 TriggerDagRunOperator 2023-06-02T20:11:10.803042+00:00 2023-06-02T20:11:11.249874+00:00 0:00:00.446832 390072 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-02T20:11:08.296109+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-02T19:00:00+00:00 EmrJobFlowSensor 2023-06-02T20:00:46.544513+00:00 2023-06-02T20:10:48.402002+00:00 0:10:01.857489 390064 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-02T20:00:44.287227+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-02T19:00:00+00:00 EmrCreateJobFlowOperator 2023-06-02T20:00:26.311159+00:00 2023-06-02T20:00:27.217436+00:00 0:00:00.906277 390062 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-02T20:00:24.267462+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-02T19:00:00+00:00 PythonOperator 2023-06-02T20:00:04.449828+00:00 2023-06-02T20:00:05.367002+00:00 0:00:00.917174 390060 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-02T20:00:02.247888+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-02T18:00:00+00:00 TriggerDagRunOperator 2023-06-02T19:10:37.774221+00:00 2023-06-02T19:10:38.199738+00:00 0:00:00.425517 390050 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-02T19:10:35.295883+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-02T18:00:00+00:00 TriggerDagRunOperator 2023-06-02T19:10:37.680737+00:00 2023-06-02T19:10:38.093584+00:00 0:00:00.412847 390049 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-02T19:10:35.295856+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-02T18:00:00+00:00 EmrJobFlowSensor 2023-06-02T19:01:25.703332+00:00 2023-06-02T19:10:27.371087+00:00 0:09:01.667755 390040 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-02T19:01:23.315949+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-02T18:00:00+00:00 EmrCreateJobFlowOperator 2023-06-02T19:00:38.918989+00:00 2023-06-02T19:00:39.754302+00:00 0:00:00.835313 390038 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-02T19:00:36.965928+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-02T18:00:00+00:00 PythonOperator 2023-06-02T19:00:19.039411+00:00 2023-06-02T19:00:19.959998+00:00 0:00:00.920587 390037 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-02T19:00:16.951958+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-02T17:00:00+00:00 TriggerDagRunOperator 2023-06-02T18:12:52.777441+00:00 2023-06-02T18:12:53.209235+00:00 0:00:00.431794 390026 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-02T18:12:50.543252+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-02T17:00:00+00:00 TriggerDagRunOperator 2023-06-02T18:12:52.693906+00:00 2023-06-02T18:12:53.121721+00:00 0:00:00.427815 390025 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-02T18:12:50.543223+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-02T17:00:00+00:00 EmrJobFlowSensor 2023-06-02T18:02:36.490844+00:00 2023-06-02T18:12:38.255499+00:00 0:10:01.764655 390018 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-02T18:02:34.415791+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-02T17:00:00+00:00 EmrCreateJobFlowOperator 2023-06-02T18:02:16.418434+00:00 2023-06-02T18:02:17.322628+00:00 0:00:00.904194 390016 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-02T18:02:14.404587+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-02T17:00:00+00:00 PythonOperator 2023-06-02T18:01:54.867683+00:00 2023-06-02T18:01:55.840401+00:00 0:00:00.972718 390014 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-02T18:01:52.386179+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-02T16:00:00+00:00 TriggerDagRunOperator 2023-06-02T17:14:23.739356+00:00 2023-06-02T17:14:24.177561+00:00 0:00:00.438205 390006 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-02T17:14:21.294678+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-02T16:00:00+00:00 TriggerDagRunOperator 2023-06-02T17:14:23.674347+00:00 2023-06-02T17:14:24.082886+00:00 0:00:00.408539 390005 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-02T17:14:21.294640+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-02T16:00:00+00:00 EmrJobFlowSensor 2023-06-02T17:02:29.966074+00:00 2023-06-02T17:12:31.929206+00:00 0:10:01.963132 389999 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-02T17:02:27.917557+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-02T16:00:00+00:00 EmrCreateJobFlowOperator 2023-06-02T17:02:07.978047+00:00 2023-06-02T17:02:08.851074+00:00 0:00:00.873027 389997 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-02T17:02:05.896715+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-02T16:00:00+00:00 PythonOperator 2023-06-02T17:01:47.901683+00:00 2023-06-02T17:01:48.816434+00:00 0:00:00.914751 389995 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-02T17:01:45.876341+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-02T15:00:00+00:00 TriggerDagRunOperator 2023-06-02T16:17:29.724779+00:00 2023-06-02T16:17:30.213763+00:00 0:00:00.488984 389988 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-02T16:17:27.519831+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-02T15:00:00+00:00 TriggerDagRunOperator 2023-06-02T16:17:29.616360+00:00 2023-06-02T16:17:30.077722+00:00 0:00:00.461362 389987 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-02T16:17:27.519859+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-02T15:00:00+00:00 EmrJobFlowSensor 2023-06-02T16:01:05.624101+00:00 2023-06-02T16:11:07.457959+00:00 0:10:01.833858 389980 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-02T16:01:03.503793+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-02T15:00:00+00:00 EmrCreateJobFlowOperator 2023-06-02T16:00:45.631291+00:00 2023-06-02T16:00:46.565428+00:00 0:00:00.934137 389978 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-02T16:00:43.505230+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-02T15:00:00+00:00 PythonOperator 2023-06-02T16:00:23.508070+00:00 2023-06-02T16:00:24.440222+00:00 0:00:00.932152 389976 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-02T16:00:21.441254+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-02T14:00:00+00:00 TriggerDagRunOperator 2023-06-02T15:18:09.920097+00:00 2023-06-02T15:18:10.322569+00:00 0:00:00.402472 389967 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-02T15:18:07.736242+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-02T14:00:00+00:00 TriggerDagRunOperator 2023-06-02T15:18:09.899657+00:00 2023-06-02T15:18:10.356290+00:00 0:00:00.456633 389966 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-02T15:18:07.736271+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-02T14:00:00+00:00 EmrJobFlowSensor 2023-06-02T15:07:57.951857+00:00 2023-06-02T15:17:59.714006+00:00 0:10:01.762149 389962 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-02T15:07:55.827513+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-02T14:00:00+00:00 EmrCreateJobFlowOperator 2023-06-02T15:07:37.807820+00:00 2023-06-02T15:07:38.712002+00:00 0:00:00.904182 389959 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-02T15:07:35.806752+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-02T14:00:00+00:00 PythonOperator 2023-06-02T15:07:15.804715+00:00 2023-06-02T15:07:16.750981+00:00 0:00:00.946266 389956 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-02T15:07:13.790403+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-02T13:00:00+00:00 TriggerDagRunOperator 2023-06-02T14:15:33.613321+00:00 2023-06-02T14:15:34.033363+00:00 0:00:00.420042 389948 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-02T14:15:31.129708+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-02T13:00:00+00:00 TriggerDagRunOperator 2023-06-02T14:15:33.563459+00:00 2023-06-02T14:15:34.030749+00:00 0:00:00.467290 389947 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-02T14:15:31.129769+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-02T13:00:00+00:00 EmrJobFlowSensor 2023-06-02T14:03:27.680605+00:00 2023-06-02T14:13:29.538468+00:00 0:10:01.857863 389941 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-02T14:03:25.630583+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-02T13:00:00+00:00 EmrCreateJobFlowOperator 2023-06-02T14:03:08.214566+00:00 2023-06-02T14:03:09.045391+00:00 0:00:00.830825 389939 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-02T14:03:05.610162+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-02T13:00:00+00:00 PythonOperator 2023-06-02T14:02:45.835581+00:00 2023-06-02T14:02:46.808909+00:00 0:00:00.973328 389937 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-02T14:02:43.592401+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-02T12:00:00+00:00 TriggerDagRunOperator 2023-06-02T13:14:34.090212+00:00 2023-06-02T13:14:34.491820+00:00 0:00:00.401608 389928 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-02T13:14:31.810913+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-02T12:00:00+00:00 TriggerDagRunOperator 2023-06-02T13:14:34.088961+00:00 2023-06-02T13:14:34.525233+00:00 0:00:00.436272 389927 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-02T13:14:31.810884+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-02T12:00:00+00:00 EmrJobFlowSensor 2023-06-02T13:04:16.341606+00:00 2023-06-02T13:14:18.174234+00:00 0:10:01.832628 389920 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-02T13:04:14.368992+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-02T12:00:00+00:00 EmrCreateJobFlowOperator 2023-06-02T13:03:56.307467+00:00 2023-06-02T13:03:57.216796+00:00 0:00:00.909329 389918 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-02T13:03:54.351556+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-02T12:00:00+00:00 PythonOperator 2023-06-02T13:03:34.661137+00:00 2023-06-02T13:03:35.654309+00:00 0:00:00.993172 389916 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-02T13:03:32.333085+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-02T11:00:00+00:00 TriggerDagRunOperator 2023-06-02T12:14:19.975266+00:00 2023-06-02T12:14:20.436395+00:00 0:00:00.461129 389906 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-02T12:14:17.630420+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-02T11:00:00+00:00 TriggerDagRunOperator 2023-06-02T12:14:19.896793+00:00 2023-06-02T12:14:20.319760+00:00 0:00:00.422967 389905 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-02T12:14:17.630392+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-02T11:00:00+00:00 EmrJobFlowSensor 2023-06-02T12:04:01.600559+00:00 2023-06-02T12:14:03.596417+00:00 0:10:01.995858 389898 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-02T12:03:59.557649+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-02T11:00:00+00:00 EmrCreateJobFlowOperator 2023-06-02T12:03:39.527706+00:00 2023-06-02T12:03:40.441256+00:00 0:00:00.913550 389896 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-02T12:03:37.534328+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-02T11:00:00+00:00 PythonOperator 2023-06-02T12:03:19.853522+00:00 2023-06-02T12:03:20.805426+00:00 0:00:00.951904 389894 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-02T12:03:17.569128+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-02T10:00:00+00:00 TriggerDagRunOperator 2023-06-02T11:11:21.723798+00:00 2023-06-02T11:11:22.144594+00:00 0:00:00.420796 389885 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-02T11:11:19.721733+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-02T10:00:00+00:00 TriggerDagRunOperator 2023-06-02T11:11:21.726043+00:00 2023-06-02T11:11:22.183428+00:00 0:00:00.457385 389884 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-02T11:11:19.721706+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-02T10:00:00+00:00 EmrJobFlowSensor 2023-06-02T11:08:11.626183+00:00 2023-06-02T11:11:12.576005+00:00 0:03:00.949822 389881 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-02T11:08:09.549260+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-02T10:00:00+00:00 EmrCreateJobFlowOperator 2023-06-02T11:00:42.122790+00:00 2023-06-02T11:00:43.226400+00:00 0:00:01.103610 389876 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-02T11:00:40.015943+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-02T10:00:00+00:00 PythonOperator 2023-06-02T11:00:21.900904+00:00 2023-06-02T11:00:22.793216+00:00 0:00:00.892312 389874 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-02T11:00:19.995346+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-02T09:00:00+00:00 TriggerDagRunOperator 2023-06-02T10:13:21.726563+00:00 2023-06-02T10:13:22.190592+00:00 0:00:00.464029 389865 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-02T10:13:19.479050+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-02T09:00:00+00:00 TriggerDagRunOperator 2023-06-02T10:13:21.711997+00:00 2023-06-02T10:13:22.109822+00:00 0:00:00.397825 389864 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-02T10:13:19.479080+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-02T09:00:00+00:00 EmrJobFlowSensor 2023-06-02T10:01:14.671384+00:00 2023-06-02T10:11:16.557935+00:00 0:10:01.886551 389858 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-02T10:01:12.631310+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-02T09:00:00+00:00 EmrCreateJobFlowOperator 2023-06-02T10:00:52.590450+00:00 2023-06-02T10:00:53.650332+00:00 0:00:01.059882 389856 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-02T10:00:50.605772+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-02T09:00:00+00:00 PythonOperator 2023-06-02T10:00:32.762722+00:00 2023-06-02T10:00:33.657939+00:00 0:00:00.895217 389854 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-02T10:00:30.584250+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-02T08:00:00+00:00 TriggerDagRunOperator 2023-06-02T09:30:48.351699+00:00 2023-06-02T09:30:48.794878+00:00 0:00:00.443179 389845 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-02T09:30:46.020946+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-02T08:00:00+00:00 TriggerDagRunOperator 2023-06-02T09:30:48.296928+00:00 2023-06-02T09:30:48.698221+00:00 0:00:00.401293 389844 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-02T09:30:46.020916+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-02T08:00:00+00:00 EmrJobFlowSensor 2023-06-02T09:00:51.325298+00:00 2023-06-02T09:10:53.068896+00:00 0:10:01.743598 389837 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-02T09:00:49.213868+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-02T08:00:00+00:00 EmrCreateJobFlowOperator 2023-06-02T09:00:31.196188+00:00 2023-06-02T09:00:32.093919+00:00 0:00:00.897731 389835 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-02T09:00:29.134329+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-02T08:00:00+00:00 PythonOperator 2023-06-02T09:00:09.325794+00:00 2023-06-02T09:00:10.223739+00:00 0:00:00.897945 389833 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-02T09:00:07.123877+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-02T07:00:00+00:00 TriggerDagRunOperator 2023-06-02T08:15:41.914994+00:00 2023-06-02T08:15:42.727948+00:00 0:00:00.812954 389824 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-02T08:15:39.501097+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-02T07:00:00+00:00 TriggerDagRunOperator 2023-06-02T08:15:41.780038+00:00 2023-06-02T08:15:42.583621+00:00 0:00:00.803583 389823 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-02T08:15:39.501125+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-02T07:00:00+00:00 EmrJobFlowSensor 2023-06-02T08:00:51.935745+00:00 2023-06-02T08:10:53.806964+00:00 0:10:01.871219 389815 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-02T08:00:49.956931+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-02T07:00:00+00:00 EmrCreateJobFlowOperator 2023-06-02T08:00:31.975275+00:00 2023-06-02T08:00:32.923097+00:00 0:00:00.947822 389813 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-02T08:00:29.936558+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-02T07:00:00+00:00 PythonOperator 2023-06-02T08:00:10.050852+00:00 2023-06-02T08:00:11.005337+00:00 0:00:00.954485 389811 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-02T08:00:07.922408+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-02T06:00:00+00:00 TriggerDagRunOperator 2023-06-02T07:18:45.948732+00:00 2023-06-02T07:18:46.477714+00:00 0:00:00.528982 389804 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-02T07:18:43.416746+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-02T06:00:00+00:00 TriggerDagRunOperator 2023-06-02T07:18:45.908329+00:00 2023-06-02T07:18:46.397738+00:00 0:00:00.489409 389803 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-02T07:18:43.416718+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-02T06:00:00+00:00 EmrJobFlowSensor 2023-06-02T07:08:35.630078+00:00 2023-06-02T07:18:37.445201+00:00 0:10:01.815123 389797 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-02T07:08:33.643980+00:00 2 default_pool