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-07T06:00:00+00:00 EmrCreateJobFlowOperator 2023-06-07T07:00:41.507576+00:00 2023-06-07T07:00:42.626897+00:00 0:00:01.119321 392404 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-07T07:00:39.456302+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-07T06:00:00+00:00 PythonOperator 2023-06-07T07:00:19.725150+00:00 2023-06-07T07:00:20.585407+00:00 0:00:00.860257 392402 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-07T07:00:17.437747+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-07T05:00:00+00:00 TriggerDagRunOperator 2023-06-07T06:11:05.330097+00:00 2023-06-07T06:11:05.658367+00:00 0:00:00.328270 392391 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-07T06:11:03.101858+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-07T05:00:00+00:00 TriggerDagRunOperator 2023-06-07T06:11:05.137692+00:00 2023-06-07T06:11:05.560251+00:00 0:00:00.422559 392390 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-07T06:11:03.101885+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-07T05:00:00+00:00 EmrJobFlowSensor 2023-06-07T06:00:50.691052+00:00 2023-06-07T06:10:52.619960+00:00 0:10:01.928908 392384 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-07T06:00:48.508274+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-07T05:00:00+00:00 EmrCreateJobFlowOperator 2023-06-07T06:00:28.656644+00:00 2023-06-07T06:00:29.482505+00:00 0:00:00.825861 392382 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-07T06:00:26.486861+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-07T05:00:00+00:00 PythonOperator 2023-06-07T06:00:08.620594+00:00 2023-06-07T06:00:09.447719+00:00 0:00:00.827125 392380 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-07T06:00:06.468321+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-07T04:00:00+00:00 TriggerDagRunOperator 2023-06-07T05:11:16.268235+00:00 2023-06-07T05:11:16.602628+00:00 0:00:00.334393 392368 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-07T05:11:14.118943+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-07T04:00:00+00:00 TriggerDagRunOperator 2023-06-07T05:11:16.125268+00:00 2023-06-07T05:11:16.565327+00:00 0:00:00.440059 392367 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-07T05:11:14.118975+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-07T04:00:00+00:00 EmrJobFlowSensor 2023-06-07T05:00:58.047653+00:00 2023-06-07T05:10:59.814549+00:00 0:10:01.766896 392360 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-07T05:00:55.803153+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-07T04:00:00+00:00 EmrCreateJobFlowOperator 2023-06-07T05:00:38.020609+00:00 2023-06-07T05:00:38.818866+00:00 0:00:00.798257 392358 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-07T05:00:35.766333+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-07T04:00:00+00:00 PythonOperator 2023-06-07T05:00:15.908442+00:00 2023-06-07T05:00:16.879219+00:00 0:00:00.970777 392356 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-07T05:00:13.746589+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-07T03:00:00+00:00 TriggerDagRunOperator 2023-06-07T04:11:11.206265+00:00 2023-06-07T04:11:11.595043+00:00 0:00:00.388778 392346 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-07T04:11:08.967830+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-07T03:00:00+00:00 TriggerDagRunOperator 2023-06-07T04:11:11.069660+00:00 2023-06-07T04:11:11.592953+00:00 0:00:00.523293 392345 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-07T04:11:08.967800+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-07T03:00:00+00:00 EmrJobFlowSensor 2023-06-07T04:01:02.721024+00:00 2023-06-07T04:11:04.472501+00:00 0:10:01.751477 392339 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-07T04:01:00.516320+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-07T03:00:00+00:00 EmrCreateJobFlowOperator 2023-06-07T04:00:40.878445+00:00 2023-06-07T04:00:41.781859+00:00 0:00:00.903414 392337 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-07T04:00:38.501662+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-07T03:00:00+00:00 PythonOperator 2023-06-07T04:00:20.629742+00:00 2023-06-07T04:00:21.683311+00:00 0:00:01.053569 392335 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-07T04:00:18.505702+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-07T02:00:00+00:00 TriggerDagRunOperator 2023-06-07T03:18:10.455763+00:00 2023-06-07T03:18:10.800530+00:00 0:00:00.344767 392324 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-07T03:18:07.900606+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-07T02:00:00+00:00 TriggerDagRunOperator 2023-06-07T03:18:10.265092+00:00 2023-06-07T03:18:10.688847+00:00 0:00:00.423755 392323 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-07T03:18:07.900577+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-07T02:00:00+00:00 EmrJobFlowSensor 2023-06-07T03:08:04.996680+00:00 2023-06-07T03:18:06.784750+00:00 0:10:01.788070 392318 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-07T03:08:02.987078+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-07T02:00:00+00:00 EmrCreateJobFlowOperator 2023-06-07T03:07:43.081594+00:00 2023-06-07T03:07:44.279564+00:00 0:00:01.197970 392315 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-07T03:07:40.979426+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-07T02:00:00+00:00 PythonOperator 2023-06-07T03:07:23.252363+00:00 2023-06-07T03:07:24.042712+00:00 0:00:00.790349 392313 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-07T03:07:20.966618+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-07T01:00:00+00:00 TriggerDagRunOperator 2023-06-07T02:11:05.638522+00:00 2023-06-07T02:11:06.046700+00:00 0:00:00.408178 392302 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-07T02:11:02.930522+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-07T01:00:00+00:00 TriggerDagRunOperator 2023-06-07T02:11:05.465078+00:00 2023-06-07T02:11:05.885660+00:00 0:00:00.420582 392301 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-07T02:11:02.930494+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-07T01:00:00+00:00 EmrJobFlowSensor 2023-06-07T02:01:59.465491+00:00 2023-06-07T02:11:01.048671+00:00 0:09:01.583180 392294 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-07T02:01:57.087547+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-07T01:00:00+00:00 EmrCreateJobFlowOperator 2023-06-07T02:00:40.792653+00:00 2023-06-07T02:00:41.656622+00:00 0:00:00.863969 392291 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-07T02:00:38.577709+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-07T01:00:00+00:00 PythonOperator 2023-06-07T02:00:20.890243+00:00 2023-06-07T02:00:22.013274+00:00 0:00:01.123031 392289 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-07T02:00:18.559845+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-07T00:00:00+00:00 TriggerDagRunOperator 2023-06-07T01:11:00.205914+00:00 2023-06-07T01:11:00.544808+00:00 0:00:00.338894 392269 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-07T01:10:57.413912+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-07T00:00:00+00:00 TriggerDagRunOperator 2023-06-07T01:10:59.955378+00:00 2023-06-07T01:11:00.449818+00:00 0:00:00.494440 392268 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-07T01:10:57.413940+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-07T00:00:00+00:00 EmrJobFlowSensor 2023-06-07T01:00:48.795800+00:00 2023-06-07T01:10:50.713679+00:00 0:10:01.917879 392260 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-07T01:00:46.783968+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-07T00:00:00+00:00 EmrCreateJobFlowOperator 2023-06-07T01:00:29.018545+00:00 2023-06-07T01:00:29.843317+00:00 0:00:00.824772 392258 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-07T01:00:26.766041+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-07T00:00:00+00:00 PythonOperator 2023-06-07T01:00:07.135931+00:00 2023-06-07T01:00:08.191514+00:00 0:00:01.055583 392256 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-07T01:00:04.743764+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-06T23:00:00+00:00 TriggerDagRunOperator 2023-06-07T00:11:24.146843+00:00 2023-06-07T00:11:24.480344+00:00 0:00:00.333501 392246 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-07T00:11:21.538257+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-06T23:00:00+00:00 TriggerDagRunOperator 2023-06-07T00:11:23.902405+00:00 2023-06-07T00:11:24.344848+00:00 0:00:00.442443 392245 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-07T00:11:21.538229+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-06T23:00:00+00:00 EmrJobFlowSensor 2023-06-07T00:00:58.700384+00:00 2023-06-07T00:11:00.444894+00:00 0:10:01.744510 392237 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-07T00:00:56.467964+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-06T23:00:00+00:00 EmrCreateJobFlowOperator 2023-06-07T00:00:36.570823+00:00 2023-06-07T00:00:37.518421+00:00 0:00:00.947598 392235 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-07T00:00:34.448556+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-06T23:00:00+00:00 PythonOperator 2023-06-07T00:00:16.753201+00:00 2023-06-07T00:00:17.586328+00:00 0:00:00.833127 392233 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-07T00:00:14.430585+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-06T22:00:00+00:00 TriggerDagRunOperator 2023-06-06T23:11:10.608747+00:00 2023-06-06T23:11:11.047074+00:00 0:00:00.438327 392223 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-06T23:11:07.903674+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-06T22:00:00+00:00 TriggerDagRunOperator 2023-06-06T23:11:10.472653+00:00 2023-06-06T23:11:10.951946+00:00 0:00:00.479293 392222 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-06T23:11:07.903702+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-06T22:00:00+00:00 EmrJobFlowSensor 2023-06-06T23:00:49.641155+00:00 2023-06-06T23:10:51.582214+00:00 0:10:01.941059 392214 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-06T23:00:46.128013+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-06T22:00:00+00:00 EmrCreateJobFlowOperator 2023-06-06T23:00:26.347708+00:00 2023-06-06T23:00:27.311947+00:00 0:00:00.964239 392211 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-06T23:00:24.111420+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-06T22:00:00+00:00 PythonOperator 2023-06-06T23:00:06.291662+00:00 2023-06-06T23:00:07.146135+00:00 0:00:00.854473 392208 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-06T23:00:04.093733+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-06T21:00:00+00:00 TriggerDagRunOperator 2023-06-06T22:11:45.761133+00:00 2023-06-06T22:11:46.102199+00:00 0:00:00.341066 392197 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-06T22:11:43.372585+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-06T21:00:00+00:00 TriggerDagRunOperator 2023-06-06T22:11:45.602279+00:00 2023-06-06T22:11:46.081956+00:00 0:00:00.479677 392196 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-06T22:11:43.372613+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-06T21:00:00+00:00 EmrJobFlowSensor 2023-06-06T22:01:21.849726+00:00 2023-06-06T22:11:23.716864+00:00 0:10:01.867138 392190 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-06T22:01:19.304369+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-06T21:00:00+00:00 EmrCreateJobFlowOperator 2023-06-06T22:00:39.320808+00:00 2023-06-06T22:00:40.250501+00:00 0:00:00.929693 392187 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-06T22:00:37.199066+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-06T21:00:00+00:00 PythonOperator 2023-06-06T22:00:17.368522+00:00 2023-06-06T22:00:18.180374+00:00 0:00:00.811852 392185 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-06T22:00:15.127345+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-06T20:00:00+00:00 TriggerDagRunOperator 2023-06-06T21:11:46.316927+00:00 2023-06-06T21:11:46.647517+00:00 0:00:00.330590 392174 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-06T21:11:43.503035+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-06T20:00:00+00:00 TriggerDagRunOperator 2023-06-06T21:11:46.119407+00:00 2023-06-06T21:11:46.567321+00:00 0:00:00.447914 392173 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-06T21:11:43.503063+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-06T20:00:00+00:00 EmrJobFlowSensor 2023-06-06T21:01:21.526040+00:00 2023-06-06T21:11:23.669020+00:00 0:10:02.142980 392166 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-06T21:01:18.765235+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-06T20:00:00+00:00 EmrCreateJobFlowOperator 2023-06-06T21:00:41.589312+00:00 2023-06-06T21:00:42.583741+00:00 0:00:00.994429 392163 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-06T21:00:39.427508+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-06T20:00:00+00:00 PythonOperator 2023-06-06T21:00:19.825339+00:00 2023-06-06T21:00:20.636068+00:00 0:00:00.810729 392161 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-06T21:00:17.413002+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-06T19:00:00+00:00 TriggerDagRunOperator 2023-06-06T20:11:12.168969+00:00 2023-06-06T20:11:12.623291+00:00 0:00:00.454322 392151 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-06T20:11:09.406410+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-06T19:00:00+00:00 TriggerDagRunOperator 2023-06-06T20:11:11.873095+00:00 2023-06-06T20:11:12.349401+00:00 0:00:00.476306 392150 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-06T20:11:09.406381+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-06T19:00:00+00:00 EmrJobFlowSensor 2023-06-06T20:00:57.698684+00:00 2023-06-06T20:10:59.576643+00:00 0:10:01.877959 392143 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-06T20:00:55.506053+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-06T19:00:00+00:00 EmrCreateJobFlowOperator 2023-06-06T20:00:35.867807+00:00 2023-06-06T20:00:36.832576+00:00 0:00:00.964769 392141 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-06T20:00:33.502655+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-06T19:00:00+00:00 PythonOperator 2023-06-06T20:00:16.444738+00:00 2023-06-06T20:00:17.259515+00:00 0:00:00.814777 392139 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-06T20:00:13.494185+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-06T18:00:00+00:00 TriggerDagRunOperator 2023-06-06T19:10:54.877583+00:00 2023-06-06T19:10:55.272530+00:00 0:00:00.394947 392126 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-06T19:10:52.504483+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-06T18:00:00+00:00 TriggerDagRunOperator 2023-06-06T19:10:54.669689+00:00 2023-06-06T19:10:55.174742+00:00 0:00:00.505053 392125 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-06T19:10:52.504520+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-06T18:00:00+00:00 EmrJobFlowSensor 2023-06-06T19:01:48.270923+00:00 2023-06-06T19:10:49.969176+00:00 0:09:01.698253 392118 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-06T19:01:46.063836+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-06T18:00:00+00:00 EmrCreateJobFlowOperator 2023-06-06T19:00:41.322735+00:00 2023-06-06T19:00:42.305268+00:00 0:00:00.982533 392116 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-06T19:00:39.215559+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-06T18:00:00+00:00 PythonOperator 2023-06-06T19:00:19.371974+00:00 2023-06-06T19:00:20.179014+00:00 0:00:00.807040 392115 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-06T19:00:17.198674+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-06T17:00:00+00:00 TriggerDagRunOperator 2023-06-06T18:10:49.115658+00:00 2023-06-06T18:10:49.496743+00:00 0:00:00.381085 392102 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-06T18:10:46.778258+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-06T17:00:00+00:00 TriggerDagRunOperator 2023-06-06T18:10:48.834631+00:00 2023-06-06T18:10:49.466229+00:00 0:00:00.631598 392101 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-06T18:10:46.778226+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-06T17:00:00+00:00 EmrJobFlowSensor 2023-06-06T18:01:41.163079+00:00 2023-06-06T18:10:42.843688+00:00 0:09:01.680609 392094 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-06T18:01:38.886325+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-06T17:00:00+00:00 EmrCreateJobFlowOperator 2023-06-06T18:00:38.962548+00:00 2023-06-06T18:00:39.784825+00:00 0:00:00.822277 392092 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-06T18:00:36.695202+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-06T17:00:00+00:00 PythonOperator 2023-06-06T18:00:19.047198+00:00 2023-06-06T18:00:20.345594+00:00 0:00:01.298396 392090 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-06T18:00:16.636972+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-06T16:00:00+00:00 TriggerDagRunOperator 2023-06-06T17:11:08.167423+00:00 2023-06-06T17:11:08.498710+00:00 0:00:00.331287 392080 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-06T17:11:05.751113+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-06T16:00:00+00:00 TriggerDagRunOperator 2023-06-06T17:11:07.956787+00:00 2023-06-06T17:11:08.405933+00:00 0:00:00.449146 392079 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-06T17:11:05.751086+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-06T16:00:00+00:00 EmrJobFlowSensor 2023-06-06T17:00:55.454453+00:00 2023-06-06T17:10:57.263255+00:00 0:10:01.808802 392071 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-06T17:00:53.255836+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-06T16:00:00+00:00 EmrCreateJobFlowOperator 2023-06-06T17:00:33.440674+00:00 2023-06-06T17:00:34.408912+00:00 0:00:00.968238 392069 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-06T17:00:31.235827+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-06T16:00:00+00:00 PythonOperator 2023-06-06T17:00:13.376645+00:00 2023-06-06T17:00:14.331970+00:00 0:00:00.955325 392067 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-06T17:00:11.215651+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-06T15:00:00+00:00 TriggerDagRunOperator 2023-06-06T16:39:21.860859+00:00 2023-06-06T16:39:22.196886+00:00 0:00:00.336027 392061 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-06T16:39:19.280938+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-06T15:00:00+00:00 TriggerDagRunOperator 2023-06-06T16:39:21.618478+00:00 2023-06-06T16:39:22.089575+00:00 0:00:00.471097 392060 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-06T16:39:19.280965+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-06T15:00:00+00:00 EmrJobFlowSensor 2023-06-06T16:08:25.080732+00:00 2023-06-06T16:18:26.790798+00:00 0:10:01.710066 392057 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-06T16:08:22.845065+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-06T15:00:00+00:00 EmrCreateJobFlowOperator 2023-06-06T16:08:03.076583+00:00 2023-06-06T16:08:04.072907+00:00 0:00:00.996324 392054 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-06T16:08:00.823155+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-06T15:00:00+00:00 PythonOperator 2023-06-06T16:00:18.016343+00:00 2023-06-06T16:00:18.838254+00:00 0:00:00.821911 392049 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-06T16:00:15.710602+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-06T14:00:00+00:00 TriggerDagRunOperator 2023-06-06T15:15:26.270653+00:00 2023-06-06T15:15:26.617761+00:00 0:00:00.347108 392040 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-06T15:15:23.883156+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-06T14:00:00+00:00 TriggerDagRunOperator 2023-06-06T15:15:26.067408+00:00 2023-06-06T15:15:26.515414+00:00 0:00:00.448006 392039 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-06T15:15:23.883184+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-06T14:00:00+00:00 EmrJobFlowSensor 2023-06-06T15:05:19.045088+00:00 2023-06-06T15:15:20.859786+00:00 0:10:01.814698 392034 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-06T15:05:16.879540+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-06T14:00:00+00:00 EmrCreateJobFlowOperator 2023-06-06T15:04:57.102276+00:00 2023-06-06T15:04:57.936491+00:00 0:00:00.834215 392031 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-06T15:04:54.861423+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-06T14:00:00+00:00 PythonOperator 2023-06-06T15:04:37.077006+00:00 2023-06-06T15:04:37.897620+00:00 0:00:00.820614 392029 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-06T15:04:34.840226+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-06T13:00:00+00:00 TriggerDagRunOperator 2023-06-06T14:17:19.188923+00:00 2023-06-06T14:17:19.527214+00:00 0:00:00.338291 392022 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-06T14:17:16.843725+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-06T13:00:00+00:00 TriggerDagRunOperator 2023-06-06T14:17:19.024079+00:00 2023-06-06T14:17:19.465323+00:00 0:00:00.441244 392021 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-06T14:17:16.843697+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-06T13:00:00+00:00 EmrJobFlowSensor 2023-06-06T14:07:08.454636+00:00 2023-06-06T14:17:10.206938+00:00 0:10:01.752302 392016 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-06T14:07:06.249293+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-06T13:00:00+00:00 EmrCreateJobFlowOperator 2023-06-06T14:06:48.302594+00:00 2023-06-06T14:06:49.205835+00:00 0:00:00.903241 392013 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-06T14:06:46.232020+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-06T13:00:00+00:00 PythonOperator 2023-06-06T14:06:26.825068+00:00 2023-06-06T14:06:28.146285+00:00 0:00:01.321217 392010 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-06T14:06:24.210416+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-06T12:00:00+00:00 TriggerDagRunOperator 2023-06-06T13:11:18.224058+00:00 2023-06-06T13:11:18.600293+00:00 0:00:00.376235 392002 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-06T13:11:16.075677+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-06T12:00:00+00:00 TriggerDagRunOperator 2023-06-06T13:11:18.123368+00:00 2023-06-06T13:11:18.613571+00:00 0:00:00.490203 392001 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-06T13:11:16.075713+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-06T12:00:00+00:00 EmrJobFlowSensor 2023-06-06T13:01:01.779994+00:00 2023-06-06T13:11:03.615818+00:00 0:10:01.835824 391995 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-06T13:00:59.759943+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-06T12:00:00+00:00 EmrCreateJobFlowOperator 2023-06-06T13:00:39.895168+00:00 2023-06-06T13:00:40.742963+00:00 0:00:00.847795 391993 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-06T13:00:37.786886+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-06T12:00:00+00:00 PythonOperator 2023-06-06T13:00:18.076249+00:00 2023-06-06T13:00:18.887133+00:00 0:00:00.810884 391991 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-06T13:00:15.788929+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-06T11:00:00+00:00 TriggerDagRunOperator 2023-06-06T12:12:04.885335+00:00 2023-06-06T12:12:05.270745+00:00 0:00:00.385410 391984 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-06T12:12:02.451885+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-06T11:00:00+00:00 TriggerDagRunOperator 2023-06-06T12:12:04.588876+00:00 2023-06-06T12:12:05.060602+00:00 0:00:00.471726 391983 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-06T12:12:02.451855+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-06T11:00:00+00:00 EmrJobFlowSensor 2023-06-06T12:01:52.428262+00:00 2023-06-06T12:11:54.231544+00:00 0:10:01.803282 391977 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-06T12:01:50.259242+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-06T11:00:00+00:00 EmrCreateJobFlowOperator 2023-06-06T12:01:30.329721+00:00 2023-06-06T12:01:31.299647+00:00 0:00:00.969926 391974 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-06T12:01:28.238126+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-06T11:00:00+00:00 PythonOperator 2023-06-06T12:01:10.793546+00:00 2023-06-06T12:01:11.703542+00:00 0:00:00.909996 391973 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-06T12:01:08.224435+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-06T10:00:00+00:00 TriggerDagRunOperator 2023-06-06T11:14:18.386680+00:00 2023-06-06T11:14:18.721749+00:00 0:00:00.335069 391965 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-06T11:14:15.979211+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-06T10:00:00+00:00 TriggerDagRunOperator 2023-06-06T11:14:18.236752+00:00 2023-06-06T11:14:18.690115+00:00 0:00:00.453363 391964 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-06T11:14:15.979239+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-06T10:00:00+00:00 EmrJobFlowSensor 2023-06-06T11:04:07.953749+00:00 2023-06-06T11:14:09.727962+00:00 0:10:01.774213 391958 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-06T11:04:05.879614+00:00 2 default_pool