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-13T06:00:00+00:00 EmrCreateJobFlowOperator 2023-05-13T07:06:19.052894+00:00 2023-05-13T07:06:19.971569+00:00 0:00:00.918675 378286 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-13T07:06:16.722066+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-13T06:00:00+00:00 PythonOperator 2023-05-13T07:05:59.646357+00:00 2023-05-13T07:06:01.001929+00:00 0:00:01.355572 378282 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-13T07:05:56.647502+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-13T05:00:00+00:00 TriggerDagRunOperator 2023-05-13T06:12:29.986097+00:00 2023-05-13T06:12:30.673493+00:00 0:00:00.687396 378272 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-13T06:12:26.992641+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-13T05:00:00+00:00 TriggerDagRunOperator 2023-05-13T06:12:29.982373+00:00 2023-05-13T06:12:30.746671+00:00 0:00:00.764298 378271 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-13T06:12:26.992595+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-13T05:00:00+00:00 EmrJobFlowSensor 2023-05-13T06:02:20.759744+00:00 2023-05-13T06:12:22.620665+00:00 0:10:01.860921 378264 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-13T06:02:18.543583+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-13T05:00:00+00:00 EmrCreateJobFlowOperator 2023-05-13T06:02:01.589772+00:00 2023-05-13T06:02:02.683070+00:00 0:00:01.093298 378262 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-13T06:01:58.445403+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-13T05:00:00+00:00 PythonOperator 2023-05-13T06:01:39.069297+00:00 2023-05-13T06:01:40.159806+00:00 0:00:01.090509 378260 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-13T06:01:36.434982+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-13T04:00:00+00:00 TriggerDagRunOperator 2023-05-13T05:27:00.567745+00:00 2023-05-13T05:27:01.008204+00:00 0:00:00.440459 378250 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-13T05:26:57.517543+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-13T04:00:00+00:00 TriggerDagRunOperator 2023-05-13T05:27:00.450765+00:00 2023-05-13T05:27:00.867922+00:00 0:00:00.417157 378249 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-13T05:26:57.517499+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-13T04:00:00+00:00 EmrJobFlowSensor 2023-05-13T05:01:33.151853+00:00 2023-05-13T05:11:35.127202+00:00 0:10:01.975349 378243 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-13T05:01:30.861747+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-13T04:00:00+00:00 EmrCreateJobFlowOperator 2023-05-13T05:01:11.122182+00:00 2023-05-13T05:01:12.070617+00:00 0:00:00.948435 378241 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-13T05:01:08.843127+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-13T04:00:00+00:00 PythonOperator 2023-05-13T05:00:51.123268+00:00 2023-05-13T05:00:52.118950+00:00 0:00:00.995682 378239 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-13T05:00:48.825895+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-13T03:00:00+00:00 TriggerDagRunOperator 2023-05-13T04:17:26.898170+00:00 2023-05-13T04:17:27.338660+00:00 0:00:00.440490 378225 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-13T04:17:24.386294+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-13T03:00:00+00:00 TriggerDagRunOperator 2023-05-13T04:17:26.839506+00:00 2023-05-13T04:17:27.178755+00:00 0:00:00.339249 378224 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-13T04:17:24.386336+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-13T03:00:00+00:00 EmrJobFlowSensor 2023-05-13T04:00:54.824617+00:00 2023-05-13T04:10:56.687974+00:00 0:10:01.863357 378216 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-13T04:00:52.388445+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-13T03:00:00+00:00 EmrCreateJobFlowOperator 2023-05-13T04:00:35.056672+00:00 2023-05-13T04:00:36.057322+00:00 0:00:01.000650 378215 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-13T04:00:32.310451+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-13T03:00:00+00:00 PythonOperator 2023-05-13T04:00:12.776659+00:00 2023-05-13T04:00:13.844545+00:00 0:00:01.067886 378212 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-13T04:00:10.298491+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-13T02:00:00+00:00 TriggerDagRunOperator 2023-05-13T03:12:08.990078+00:00 2023-05-13T03:12:09.445758+00:00 0:00:00.455680 378197 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-13T03:12:06.632102+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-13T02:00:00+00:00 TriggerDagRunOperator 2023-05-13T03:12:08.866861+00:00 2023-05-13T03:12:09.224423+00:00 0:00:00.357562 378196 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-13T03:12:06.632137+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-13T02:00:00+00:00 EmrJobFlowSensor 2023-05-13T03:11:49.315847+00:00 2023-05-13T03:11:49.798067+00:00 0:00:00.482220 378193 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-13T03:11:46.615249+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-13T02:00:00+00:00 EmrCreateJobFlowOperator 2023-05-13T03:00:30.335078+00:00 2023-05-13T03:00:31.232927+00:00 0:00:00.897849 378190 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-13T03:00:28.025153+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-13T02:00:00+00:00 PythonOperator 2023-05-13T03:00:08.610440+00:00 2023-05-13T03:00:09.767568+00:00 0:00:01.157128 378189 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-13T03:00:06.008284+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-13T01:00:00+00:00 TriggerDagRunOperator 2023-05-13T02:39:22.655309+00:00 2023-05-13T02:39:23.084907+00:00 0:00:00.429598 378179 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-13T02:39:19.706375+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-13T01:00:00+00:00 TriggerDagRunOperator 2023-05-13T02:39:22.558651+00:00 2023-05-13T02:39:22.893862+00:00 0:00:00.335211 378178 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-13T02:39:19.706338+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-13T01:00:00+00:00 EmrJobFlowSensor 2023-05-13T02:20:06.559867+00:00 2023-05-13T02:30:08.584512+00:00 0:10:02.024645 378173 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-13T02:20:04.280207+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-13T01:00:00+00:00 EmrCreateJobFlowOperator 2023-05-13T02:19:44.378231+00:00 2023-05-13T02:19:45.666647+00:00 0:00:01.288416 378170 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-13T02:19:42.209648+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-13T01:00:00+00:00 PythonOperator 2023-05-13T02:19:25.149665+00:00 2023-05-13T02:19:27.046198+00:00 0:00:01.896533 378167 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-13T02:19:22.194901+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-13T00:00:00+00:00 TriggerDagRunOperator 2023-05-13T01:11:27.119255+00:00 2023-05-13T01:11:27.572579+00:00 0:00:00.453324 378147 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-13T01:11:23.927745+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-13T00:00:00+00:00 TriggerDagRunOperator 2023-05-13T01:11:26.899191+00:00 2023-05-13T01:11:27.260113+00:00 0:00:00.360922 378146 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-13T01:11:23.927794+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-13T00:00:00+00:00 EmrJobFlowSensor 2023-05-13T01:01:05.069075+00:00 2023-05-13T01:11:07.011569+00:00 0:10:01.942494 378139 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-13T01:01:02.743636+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-13T00:00:00+00:00 EmrCreateJobFlowOperator 2023-05-13T01:00:42.938369+00:00 2023-05-13T01:00:44.069094+00:00 0:00:01.130725 378137 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-13T01:00:40.711105+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-13T00:00:00+00:00 PythonOperator 2023-05-13T01:00:20.918199+00:00 2023-05-13T01:00:21.953475+00:00 0:00:01.035276 378135 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-13T01:00:18.692703+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-12T23:00:00+00:00 TriggerDagRunOperator 2023-05-13T00:13:31.097865+00:00 2023-05-13T00:13:31.434117+00:00 0:00:00.336252 378121 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-13T00:13:27.612559+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-12T23:00:00+00:00 TriggerDagRunOperator 2023-05-13T00:13:30.623246+00:00 2023-05-13T00:13:31.123782+00:00 0:00:00.500536 378120 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-13T00:13:27.612528+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-12T23:00:00+00:00 EmrJobFlowSensor 2023-05-13T00:01:03.185993+00:00 2023-05-13T00:11:05.180074+00:00 0:10:01.994081 378113 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-13T00:01:01.005921+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-12T23:00:00+00:00 EmrCreateJobFlowOperator 2023-05-13T00:00:41.192729+00:00 2023-05-13T00:00:42.206887+00:00 0:00:01.014158 378111 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-13T00:00:38.941268+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-12T23:00:00+00:00 PythonOperator 2023-05-13T00:00:21.345364+00:00 2023-05-13T00:00:22.407942+00:00 0:00:01.062578 378109 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-13T00:00:18.920045+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-12T22:00:00+00:00 TriggerDagRunOperator 2023-05-12T23:10:26.475920+00:00 2023-05-12T23:10:26.871410+00:00 0:00:00.395490 378094 airflow-worker-3.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-12T23:10:24.232647+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-12T22:00:00+00:00 TriggerDagRunOperator 2023-05-12T23:10:26.426175+00:00 2023-05-12T23:10:26.791426+00:00 0:00:00.365251 378093 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-12T23:10:24.232677+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-12T22:00:00+00:00 EmrJobFlowSensor 2023-05-12T23:07:16.369235+00:00 2023-05-12T23:10:17.551457+00:00 0:03:01.182222 378088 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-12T23:07:13.991758+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-12T22:00:00+00:00 EmrCreateJobFlowOperator 2023-05-12T23:00:34.366095+00:00 2023-05-12T23:00:35.355323+00:00 0:00:00.989228 378083 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-12T23:00:31.791918+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-12T22:00:00+00:00 PythonOperator 2023-05-12T23:00:13.421392+00:00 2023-05-12T23:00:14.573331+00:00 0:00:01.151939 378080 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-12T23:00:09.793656+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-12T21:00:00+00:00 TriggerDagRunOperator 2023-05-12T22:12:08.395766+00:00 2023-05-12T22:12:08.962067+00:00 0:00:00.566301 378066 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-12T22:12:05.935429+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-12T21:00:00+00:00 TriggerDagRunOperator 2023-05-12T22:12:08.321949+00:00 2023-05-12T22:12:08.852369+00:00 0:00:00.530420 378065 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-12T22:12:05.935400+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-12T21:00:00+00:00 EmrJobFlowSensor 2023-05-12T22:01:56.309266+00:00 2023-05-12T22:11:58.159717+00:00 0:10:01.850451 378059 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-12T22:01:54.165702+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-12T21:00:00+00:00 EmrCreateJobFlowOperator 2023-05-12T22:01:35.602638+00:00 2023-05-12T22:01:36.438209+00:00 0:00:00.835571 378057 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-12T22:01:32.140266+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-12T21:00:00+00:00 PythonOperator 2023-05-12T22:01:14.340912+00:00 2023-05-12T22:01:15.352570+00:00 0:00:01.011658 378055 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-12T22:01:12.124129+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-12T20:00:00+00:00 TriggerDagRunOperator 2023-05-12T21:11:07.409858+00:00 2023-05-12T21:11:07.753931+00:00 0:00:00.344073 378040 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-12T21:11:05.225548+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-12T20:00:00+00:00 TriggerDagRunOperator 2023-05-12T21:11:07.424505+00:00 2023-05-12T21:11:07.860834+00:00 0:00:00.436329 378039 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-12T21:11:05.225513+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-12T20:00:00+00:00 EmrJobFlowSensor 2023-05-12T21:00:50.935495+00:00 2023-05-12T21:10:52.829859+00:00 0:10:01.894364 378032 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-12T21:00:48.714879+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-12T20:00:00+00:00 EmrCreateJobFlowOperator 2023-05-12T21:00:28.840859+00:00 2023-05-12T21:00:29.751420+00:00 0:00:00.910561 378030 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-12T21:00:26.670579+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-12T20:00:00+00:00 PythonOperator 2023-05-12T21:00:09.228264+00:00 2023-05-12T21:00:10.220974+00:00 0:00:00.992710 378028 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-12T21:00:06.652057+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-12T19:00:00+00:00 TriggerDagRunOperator 2023-05-12T20:14:57.169228+00:00 2023-05-12T20:14:57.512854+00:00 0:00:00.343626 378014 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-12T20:14:54.615874+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-12T19:00:00+00:00 TriggerDagRunOperator 2023-05-12T20:14:56.826646+00:00 2023-05-12T20:14:57.504491+00:00 0:00:00.677845 378013 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-12T20:14:54.615846+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-12T19:00:00+00:00 EmrJobFlowSensor 2023-05-12T20:00:52.425891+00:00 2023-05-12T20:10:54.302234+00:00 0:10:01.876343 378008 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-12T20:00:50.256490+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-12T19:00:00+00:00 EmrCreateJobFlowOperator 2023-05-12T20:00:30.806665+00:00 2023-05-12T20:00:31.763678+00:00 0:00:00.957013 378006 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-12T20:00:28.322527+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-12T19:00:00+00:00 PythonOperator 2023-05-12T20:00:10.590670+00:00 2023-05-12T20:00:11.677806+00:00 0:00:01.087136 378004 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-12T20:00:08.145398+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-12T18:00:00+00:00 TriggerDagRunOperator 2023-05-12T19:11:11.733687+00:00 2023-05-12T19:11:12.230462+00:00 0:00:00.496775 377989 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-12T19:11:08.921505+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-12T18:00:00+00:00 TriggerDagRunOperator 2023-05-12T19:11:11.707236+00:00 2023-05-12T19:11:12.188680+00:00 0:00:00.481444 377988 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-12T19:11:08.921550+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-12T18:00:00+00:00 EmrJobFlowSensor 2023-05-12T19:00:55.255327+00:00 2023-05-12T19:10:56.982483+00:00 0:10:01.727156 377980 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-12T19:00:52.991499+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-12T18:00:00+00:00 EmrCreateJobFlowOperator 2023-05-12T19:00:33.972938+00:00 2023-05-12T19:00:34.952155+00:00 0:00:00.979217 377979 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-12T19:00:30.911405+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-12T18:00:00+00:00 PythonOperator 2023-05-12T19:00:13.159891+00:00 2023-05-12T19:00:14.169893+00:00 0:00:01.010002 377978 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-12T19:00:10.903481+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-12T17:00:00+00:00 TriggerDagRunOperator 2023-05-12T18:13:33.823334+00:00 2023-05-12T18:13:34.286876+00:00 0:00:00.463542 377964 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-12T18:13:31.299898+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-12T17:00:00+00:00 TriggerDagRunOperator 2023-05-12T18:13:33.744856+00:00 2023-05-12T18:13:34.108511+00:00 0:00:00.363655 377963 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-12T18:13:31.299941+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-12T17:00:00+00:00 EmrJobFlowSensor 2023-05-12T18:03:14.468399+00:00 2023-05-12T18:13:16.343844+00:00 0:10:01.875445 377956 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-12T18:03:12.289558+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-12T17:00:00+00:00 EmrCreateJobFlowOperator 2023-05-12T18:02:54.386142+00:00 2023-05-12T18:02:55.358886+00:00 0:00:00.972744 377955 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-12T18:02:52.227475+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-12T17:00:00+00:00 PythonOperator 2023-05-12T18:02:32.709787+00:00 2023-05-12T18:02:33.687134+00:00 0:00:00.977347 377953 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-12T18:02:30.224534+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-12T16:00:00+00:00 TriggerDagRunOperator 2023-05-12T17:11:16.646775+00:00 2023-05-12T17:11:17.086385+00:00 0:00:00.439610 377940 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-12T17:11:14.138150+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-12T16:00:00+00:00 TriggerDagRunOperator 2023-05-12T17:11:16.527023+00:00 2023-05-12T17:11:16.893679+00:00 0:00:00.366656 377939 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-12T17:11:14.138201+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-12T16:00:00+00:00 EmrJobFlowSensor 2023-05-12T17:01:00.942974+00:00 2023-05-12T17:11:02.841477+00:00 0:10:01.898503 377933 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-12T17:00:58.599070+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-12T16:00:00+00:00 EmrCreateJobFlowOperator 2023-05-12T17:00:39.193942+00:00 2023-05-12T17:00:40.077831+00:00 0:00:00.883889 377931 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-12T17:00:36.601425+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-12T16:00:00+00:00 PythonOperator 2023-05-12T17:00:16.842422+00:00 2023-05-12T17:00:17.894379+00:00 0:00:01.051957 377929 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-12T17:00:14.492635+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-12T15:00:00+00:00 TriggerDagRunOperator 2023-05-12T16:14:18.432002+00:00 2023-05-12T16:14:18.920543+00:00 0:00:00.488541 377915 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-12T16:14:15.581766+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-12T15:00:00+00:00 TriggerDagRunOperator 2023-05-12T16:14:18.339031+00:00 2023-05-12T16:14:18.719539+00:00 0:00:00.380508 377914 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-12T16:14:15.581699+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-12T15:00:00+00:00 EmrJobFlowSensor 2023-05-12T16:02:13.033483+00:00 2023-05-12T16:12:14.827713+00:00 0:10:01.794230 377907 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-12T16:02:10.853087+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-12T15:00:00+00:00 EmrCreateJobFlowOperator 2023-05-12T16:01:51.017647+00:00 2023-05-12T16:01:51.834759+00:00 0:00:00.817112 377905 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-12T16:01:48.819494+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-12T15:00:00+00:00 PythonOperator 2023-05-12T16:01:31.311194+00:00 2023-05-12T16:01:32.379228+00:00 0:00:01.068034 377903 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-12T16:01:28.802300+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-12T14:00:00+00:00 TriggerDagRunOperator 2023-05-12T15:43:07.768217+00:00 2023-05-12T15:43:08.205458+00:00 0:00:00.437241 377893 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-12T15:43:05.206449+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-12T14:00:00+00:00 TriggerDagRunOperator 2023-05-12T15:43:07.717511+00:00 2023-05-12T15:43:08.058276+00:00 0:00:00.340765 377892 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-12T15:43:05.206419+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-12T14:00:00+00:00 EmrJobFlowSensor 2023-05-12T15:31:56.779586+00:00 2023-05-12T15:42:58.638670+00:00 0:11:01.859084 377887 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-12T15:31:54.631156+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-12T14:00:00+00:00 EmrCreateJobFlowOperator 2023-05-12T15:31:36.756927+00:00 2023-05-12T15:31:37.480455+00:00 0:00:00.723528 377884 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-12T15:31:34.611278+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-12T14:00:00+00:00 PythonOperator 2023-05-12T15:31:15.269182+00:00 2023-05-12T15:31:16.340241+00:00 0:00:01.071059 377881 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-12T15:31:12.594801+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-12T13:00:00+00:00 TriggerDagRunOperator 2023-05-12T14:15:56.690053+00:00 2023-05-12T14:15:57.136060+00:00 0:00:00.446007 377871 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-12T14:15:53.834682+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-12T13:00:00+00:00 TriggerDagRunOperator 2023-05-12T14:15:56.431010+00:00 2023-05-12T14:15:56.783643+00:00 0:00:00.352633 377870 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-12T14:15:53.834653+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-12T13:00:00+00:00 EmrJobFlowSensor 2023-05-12T14:01:01.569637+00:00 2023-05-12T14:12:04.017078+00:00 0:11:02.447441 377862 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-12T14:00:59.184076+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-12T13:00:00+00:00 EmrCreateJobFlowOperator 2023-05-12T14:00:39.389326+00:00 2023-05-12T14:00:40.142929+00:00 0:00:00.753603 377860 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-12T14:00:37.145837+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-12T13:00:00+00:00 PythonOperator 2023-05-12T14:00:17.317752+00:00 2023-05-12T14:00:18.338232+00:00 0:00:01.020480 377858 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-12T14:00:15.056777+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-12T12:00:00+00:00 TriggerDagRunOperator 2023-05-12T13:13:49.718152+00:00 2023-05-12T13:13:50.181393+00:00 0:00:00.463241 377843 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-12T13:13:46.955834+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-12T12:00:00+00:00 TriggerDagRunOperator 2023-05-12T13:13:49.675328+00:00 2023-05-12T13:13:50.017467+00:00 0:00:00.342139 377842 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-12T13:13:46.955796+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-12T12:00:00+00:00 EmrJobFlowSensor 2023-05-12T13:00:54.666329+00:00 2023-05-12T13:10:56.537901+00:00 0:10:01.871572 377840 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-12T13:00:52.295949+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-12T12:00:00+00:00 EmrCreateJobFlowOperator 2023-05-12T13:00:34.367810+00:00 2023-05-12T13:00:35.219453+00:00 0:00:00.851643 377838 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-12T13:00:32.226846+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-12T12:00:00+00:00 PythonOperator 2023-05-12T13:00:12.445460+00:00 2023-05-12T13:00:13.471406+00:00 0:00:01.025946 377836 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-12T13:00:10.209596+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-12T11:00:00+00:00 TriggerDagRunOperator 2023-05-12T12:24:24.033409+00:00 2023-05-12T12:24:24.656752+00:00 0:00:00.623343 377825 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-12T12:24:21.557013+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-12T11:00:00+00:00 TriggerDagRunOperator 2023-05-12T12:24:23.909874+00:00 2023-05-12T12:24:24.260132+00:00 0:00:00.350258 377824 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-12T12:24:21.556985+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-12T11:00:00+00:00 EmrJobFlowSensor 2023-05-12T12:14:07.054100+00:00 2023-05-12T12:24:08.820446+00:00 0:10:01.766346 377821 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-12T12:14:04.859867+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-12T11:00:00+00:00 EmrCreateJobFlowOperator 2023-05-12T12:13:45.425282+00:00 2023-05-12T12:13:46.276280+00:00 0:00:00.850998 377818 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-12T12:13:42.837960+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-12T11:00:00+00:00 PythonOperator 2023-05-12T12:13:27.073472+00:00 2023-05-12T12:13:28.556798+00:00 0:00:01.483326 377815 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-12T12:13:22.822255+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-12T10:00:00+00:00 TriggerDagRunOperator 2023-05-12T11:19:16.416110+00:00 2023-05-12T11:19:16.885249+00:00 0:00:00.469139 377800 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-12T11:19:13.839883+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-12T10:00:00+00:00 TriggerDagRunOperator 2023-05-12T11:19:16.055234+00:00 2023-05-12T11:19:16.391878+00:00 0:00:00.336644 377799 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-12T11:19:13.839915+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-12T10:00:00+00:00 EmrJobFlowSensor 2023-05-12T11:01:05.261120+00:00 2023-05-12T11:11:07.181368+00:00 0:10:01.920248 377795 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-12T11:01:02.916467+00:00 2 default_pool