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-21T05:00:00+00:00 EmrCreateJobFlowOperator 2023-06-21T06:00:39.448960+00:00 2023-06-21T06:00:40.317555+00:00 0:00:00.868595 395443 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-21T06:00:37.451047+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-21T05:00:00+00:00 PythonOperator 2023-06-21T06:00:17.491320+00:00 2023-06-21T06:00:18.800450+00:00 0:00:01.309130 395441 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-21T06:00:15.413096+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-21T04:00:00+00:00 TriggerDagRunOperator 2023-06-21T05:16:49.101778+00:00 2023-06-21T05:16:49.609561+00:00 0:00:00.507783 395432 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-21T05:16:46.548115+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-21T04:00:00+00:00 TriggerDagRunOperator 2023-06-21T05:16:48.685204+00:00 2023-06-21T05:16:49.292474+00:00 0:00:00.607270 395431 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-21T05:16:46.548088+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-21T04:00:00+00:00 EmrJobFlowSensor 2023-06-21T05:01:00.400064+00:00 2023-06-21T05:11:02.402771+00:00 0:10:02.002707 395424 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-21T05:00:57.950210+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-21T04:00:00+00:00 EmrCreateJobFlowOperator 2023-06-21T05:00:38.203383+00:00 2023-06-21T05:00:39.188530+00:00 0:00:00.985147 395422 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-21T05:00:35.891960+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-21T04:00:00+00:00 PythonOperator 2023-06-21T05:00:16.583153+00:00 2023-06-21T05:00:17.605157+00:00 0:00:01.022004 395420 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-21T05:00:13.872732+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-21T03:00:00+00:00 TriggerDagRunOperator 2023-06-21T04:11:04.882508+00:00 2023-06-21T04:11:05.377021+00:00 0:00:00.494513 395409 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-21T04:11:02.498146+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-21T03:00:00+00:00 TriggerDagRunOperator 2023-06-21T04:11:04.546067+00:00 2023-06-21T04:11:04.976994+00:00 0:00:00.430927 395408 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-21T04:11:02.498118+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-21T03:00:00+00:00 EmrJobFlowSensor 2023-06-21T04:00:58.668671+00:00 2023-06-21T04:11:00.675716+00:00 0:10:02.007045 395400 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-21T04:00:56.408992+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-21T03:00:00+00:00 EmrCreateJobFlowOperator 2023-06-21T04:00:36.743182+00:00 2023-06-21T04:00:37.756621+00:00 0:00:01.013439 395398 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-21T04:00:34.391613+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-21T03:00:00+00:00 PythonOperator 2023-06-21T04:00:14.761752+00:00 2023-06-21T04:00:15.755649+00:00 0:00:00.993897 395396 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-21T04:00:12.402750+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-21T02:00:00+00:00 TriggerDagRunOperator 2023-06-21T03:11:13.057569+00:00 2023-06-21T03:11:13.529569+00:00 0:00:00.472000 395386 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-21T03:11:10.825155+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-21T02:00:00+00:00 TriggerDagRunOperator 2023-06-21T03:11:12.835737+00:00 2023-06-21T03:11:13.276397+00:00 0:00:00.440660 395385 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-21T03:11:10.825191+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-21T02:00:00+00:00 EmrJobFlowSensor 2023-06-21T03:00:57.557000+00:00 2023-06-21T03:10:59.477394+00:00 0:10:01.920394 395378 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-21T03:00:55.313252+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-21T02:00:00+00:00 EmrCreateJobFlowOperator 2023-06-21T03:00:37.334292+00:00 2023-06-21T03:00:38.238939+00:00 0:00:00.904647 395376 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-21T03:00:35.296934+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-21T02:00:00+00:00 PythonOperator 2023-06-21T03:00:15.876506+00:00 2023-06-21T03:00:17.029322+00:00 0:00:01.152816 395374 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-21T03:00:13.278634+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-21T01:00:00+00:00 TriggerDagRunOperator 2023-06-21T02:12:44.027583+00:00 2023-06-21T02:12:44.486481+00:00 0:00:00.458898 395364 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-21T02:12:41.412953+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-21T01:00:00+00:00 TriggerDagRunOperator 2023-06-21T02:12:43.625855+00:00 2023-06-21T02:12:44.031766+00:00 0:00:00.405911 395363 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-21T02:12:41.412985+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-21T01:00:00+00:00 EmrJobFlowSensor 2023-06-21T02:00:50.443816+00:00 2023-06-21T02:11:52.668841+00:00 0:11:02.225025 395356 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-21T02:00:48.245022+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-21T01:00:00+00:00 EmrCreateJobFlowOperator 2023-06-21T02:00:30.641774+00:00 2023-06-21T02:00:31.670653+00:00 0:00:01.028879 395354 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-21T02:00:28.227663+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-21T01:00:00+00:00 PythonOperator 2023-06-21T02:00:08.768100+00:00 2023-06-21T02:00:09.822190+00:00 0:00:01.054090 395352 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-21T02:00:06.209677+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-21T00:00:00+00:00 TriggerDagRunOperator 2023-06-21T01:11:21.196381+00:00 2023-06-21T01:11:21.701080+00:00 0:00:00.504699 395330 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-21T01:11:18.864753+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-21T00:00:00+00:00 TriggerDagRunOperator 2023-06-21T01:11:20.752601+00:00 2023-06-21T01:11:21.220055+00:00 0:00:00.467454 395329 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-21T01:11:18.864783+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-21T00:00:00+00:00 EmrJobFlowSensor 2023-06-21T01:01:06.554122+00:00 2023-06-21T01:11:08.380162+00:00 0:10:01.826040 395323 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-21T01:01:04.670116+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-21T00:00:00+00:00 EmrCreateJobFlowOperator 2023-06-21T01:00:44.934162+00:00 2023-06-21T01:00:46.057835+00:00 0:00:01.123673 395321 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-21T01:00:42.655025+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-21T00:00:00+00:00 PythonOperator 2023-06-21T01:00:24.573398+00:00 2023-06-21T01:00:25.458980+00:00 0:00:00.885582 395319 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-21T01:00:22.633503+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-20T23:00:00+00:00 TriggerDagRunOperator 2023-06-21T00:11:17.735702+00:00 2023-06-21T00:11:18.202457+00:00 0:00:00.466755 395307 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-21T00:11:15.448216+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-20T23:00:00+00:00 TriggerDagRunOperator 2023-06-21T00:11:17.522574+00:00 2023-06-21T00:11:17.933388+00:00 0:00:00.410814 395306 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-21T00:11:15.448248+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-20T23:00:00+00:00 EmrJobFlowSensor 2023-06-21T00:01:02.474368+00:00 2023-06-21T00:11:04.495552+00:00 0:10:02.021184 395300 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-21T00:01:00.176631+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-20T23:00:00+00:00 EmrCreateJobFlowOperator 2023-06-21T00:00:40.423930+00:00 2023-06-21T00:00:41.380046+00:00 0:00:00.956116 395298 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-21T00:00:38.152449+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-20T23:00:00+00:00 PythonOperator 2023-06-21T00:00:20.410041+00:00 2023-06-21T00:00:21.329399+00:00 0:00:00.919358 395296 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-21T00:00:18.132908+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-20T22:00:00+00:00 TriggerDagRunOperator 2023-06-20T23:11:06.593670+00:00 2023-06-20T23:11:07.067945+00:00 0:00:00.474275 395283 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-20T23:11:04.262794+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-20T22:00:00+00:00 TriggerDagRunOperator 2023-06-20T23:11:06.224754+00:00 2023-06-20T23:11:06.646681+00:00 0:00:00.421927 395282 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-20T23:11:04.262827+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-20T22:00:00+00:00 EmrJobFlowSensor 2023-06-20T23:00:49.049470+00:00 2023-06-20T23:10:51.085938+00:00 0:10:02.036468 395274 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-20T23:00:47.020521+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-20T22:00:00+00:00 EmrCreateJobFlowOperator 2023-06-20T23:00:26.841764+00:00 2023-06-20T23:00:27.923487+00:00 0:00:01.081723 395271 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-20T23:00:24.944838+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-20T22:00:00+00:00 PythonOperator 2023-06-20T23:00:07.265581+00:00 2023-06-20T23:00:08.229505+00:00 0:00:00.963924 395268 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-20T23:00:04.929613+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-20T21:00:00+00:00 TriggerDagRunOperator 2023-06-20T22:11:09.024813+00:00 2023-06-20T22:11:09.485737+00:00 0:00:00.460924 395257 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-20T22:11:06.751492+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-20T21:00:00+00:00 TriggerDagRunOperator 2023-06-20T22:11:08.714874+00:00 2023-06-20T22:11:09.165066+00:00 0:00:00.450192 395256 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-20T22:11:06.751458+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-20T21:00:00+00:00 EmrJobFlowSensor 2023-06-20T22:00:47.344385+00:00 2023-06-20T22:10:48.978096+00:00 0:10:01.633711 395249 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-20T22:00:45.421780+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-20T21:00:00+00:00 EmrCreateJobFlowOperator 2023-06-20T22:00:27.661170+00:00 2023-06-20T22:00:28.637941+00:00 0:00:00.976771 395247 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-20T22:00:25.377296+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-20T21:00:00+00:00 PythonOperator 2023-06-20T22:00:05.701325+00:00 2023-06-20T22:00:06.670058+00:00 0:00:00.968733 395245 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-20T22:00:03.352246+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-20T20:00:00+00:00 TriggerDagRunOperator 2023-06-20T21:11:11.389658+00:00 2023-06-20T21:11:11.857262+00:00 0:00:00.467604 395234 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-20T21:11:09.130526+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-20T20:00:00+00:00 TriggerDagRunOperator 2023-06-20T21:11:11.203025+00:00 2023-06-20T21:11:11.597324+00:00 0:00:00.394299 395233 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-20T21:11:09.130498+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-20T20:00:00+00:00 EmrJobFlowSensor 2023-06-20T21:01:00.319886+00:00 2023-06-20T21:11:02.317795+00:00 0:10:01.997909 395227 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-20T21:00:57.968202+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-20T20:00:00+00:00 EmrCreateJobFlowOperator 2023-06-20T21:00:39.866711+00:00 2023-06-20T21:00:40.732199+00:00 0:00:00.865488 395225 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-20T21:00:37.938699+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-20T20:00:00+00:00 PythonOperator 2023-06-20T21:00:18.135414+00:00 2023-06-20T21:00:19.121212+00:00 0:00:00.985798 395223 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-20T21:00:15.886065+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-20T19:00:00+00:00 TriggerDagRunOperator 2023-06-20T20:11:23.352839+00:00 2023-06-20T20:11:23.817106+00:00 0:00:00.464267 395211 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-20T20:11:21.158197+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-20T19:00:00+00:00 TriggerDagRunOperator 2023-06-20T20:11:23.097322+00:00 2023-06-20T20:11:23.488792+00:00 0:00:00.391470 395210 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-20T20:11:21.158227+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-20T19:00:00+00:00 EmrJobFlowSensor 2023-06-20T20:01:03.186823+00:00 2023-06-20T20:11:04.868574+00:00 0:10:01.681751 395204 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-20T20:01:01.240405+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-20T19:00:00+00:00 EmrCreateJobFlowOperator 2023-06-20T20:00:43.418355+00:00 2023-06-20T20:00:44.410066+00:00 0:00:00.991711 395202 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-20T20:00:41.216931+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-20T19:00:00+00:00 PythonOperator 2023-06-20T20:00:21.451370+00:00 2023-06-20T20:00:22.376531+00:00 0:00:00.925161 395200 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-20T20:00:19.198275+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-20T18:00:00+00:00 TriggerDagRunOperator 2023-06-20T19:11:11.578615+00:00 2023-06-20T19:11:12.071869+00:00 0:00:00.493254 395186 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-20T19:11:09.231151+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-20T18:00:00+00:00 TriggerDagRunOperator 2023-06-20T19:11:11.162232+00:00 2023-06-20T19:11:11.564933+00:00 0:00:00.402701 395185 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-20T19:11:09.231121+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-20T18:00:00+00:00 EmrJobFlowSensor 2023-06-20T19:00:55.303573+00:00 2023-06-20T19:10:57.254213+00:00 0:10:01.950640 395178 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-20T19:00:52.919826+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-20T18:00:00+00:00 EmrCreateJobFlowOperator 2023-06-20T19:00:32.835206+00:00 2023-06-20T19:00:33.867174+00:00 0:00:01.031968 395177 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-20T19:00:30.898213+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-20T18:00:00+00:00 PythonOperator 2023-06-20T19:00:13.253007+00:00 2023-06-20T19:00:14.291507+00:00 0:00:01.038500 395176 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-20T19:00:10.879866+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-20T17:00:00+00:00 TriggerDagRunOperator 2023-06-20T18:10:52.491712+00:00 2023-06-20T18:10:52.995149+00:00 0:00:00.503437 395162 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-20T18:10:50.136754+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-20T17:00:00+00:00 TriggerDagRunOperator 2023-06-20T18:10:52.153947+00:00 2023-06-20T18:10:52.551820+00:00 0:00:00.397873 395161 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-20T18:10:50.136718+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-20T17:00:00+00:00 EmrJobFlowSensor 2023-06-20T18:00:45.885325+00:00 2023-06-20T18:10:47.564985+00:00 0:10:01.679660 395154 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-20T18:00:43.938325+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-20T17:00:00+00:00 EmrCreateJobFlowOperator 2023-06-20T18:00:26.294377+00:00 2023-06-20T18:00:27.293941+00:00 0:00:00.999564 395153 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-20T18:00:23.921016+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-20T17:00:00+00:00 PythonOperator 2023-06-20T18:00:04.561453+00:00 2023-06-20T18:00:05.574743+00:00 0:00:01.013290 395151 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-20T18:00:01.900518+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-20T16:00:00+00:00 TriggerDagRunOperator 2023-06-20T17:11:17.416785+00:00 2023-06-20T17:11:17.914175+00:00 0:00:00.497390 395140 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-20T17:11:15.120261+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-20T16:00:00+00:00 TriggerDagRunOperator 2023-06-20T17:11:17.039828+00:00 2023-06-20T17:11:17.431121+00:00 0:00:00.391293 395139 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-20T17:11:15.120294+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-20T16:00:00+00:00 EmrJobFlowSensor 2023-06-20T17:01:02.439579+00:00 2023-06-20T17:11:04.197958+00:00 0:10:01.758379 395130 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-20T17:01:00.461397+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-20T16:00:00+00:00 EmrCreateJobFlowOperator 2023-06-20T17:00:42.585797+00:00 2023-06-20T17:00:43.524860+00:00 0:00:00.939063 395129 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-20T17:00:40.437983+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-20T16:00:00+00:00 PythonOperator 2023-06-20T17:00:20.364731+00:00 2023-06-20T17:00:21.211302+00:00 0:00:00.846571 395128 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-20T17:00:18.420987+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-20T15:00:00+00:00 TriggerDagRunOperator 2023-06-20T16:15:16.805853+00:00 2023-06-20T16:15:17.301966+00:00 0:00:00.496113 395118 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-20T16:15:14.252773+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-20T15:00:00+00:00 TriggerDagRunOperator 2023-06-20T16:15:16.334960+00:00 2023-06-20T16:15:16.731424+00:00 0:00:00.396464 395117 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-20T16:15:14.252800+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-20T15:00:00+00:00 EmrJobFlowSensor 2023-06-20T16:01:46.270077+00:00 2023-06-20T16:11:48.154176+00:00 0:10:01.884099 395111 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-20T16:01:44.000127+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-20T15:00:00+00:00 EmrCreateJobFlowOperator 2023-06-20T16:01:23.842285+00:00 2023-06-20T16:01:24.708644+00:00 0:00:00.866359 395108 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-20T16:01:21.978249+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-20T15:00:00+00:00 PythonOperator 2023-06-20T16:01:04.132458+00:00 2023-06-20T16:01:05.183534+00:00 0:00:01.051076 395107 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-20T16:01:01.958304+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-20T14:00:00+00:00 TriggerDagRunOperator 2023-06-20T15:11:16.521690+00:00 2023-06-20T15:11:16.998527+00:00 0:00:00.476837 395094 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-20T15:11:14.342006+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-20T14:00:00+00:00 TriggerDagRunOperator 2023-06-20T15:11:16.223163+00:00 2023-06-20T15:11:16.626128+00:00 0:00:00.402965 395093 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-20T15:11:14.341970+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-20T14:00:00+00:00 EmrJobFlowSensor 2023-06-20T15:01:00.861106+00:00 2023-06-20T15:11:02.884031+00:00 0:10:02.022925 395089 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-20T15:00:58.631492+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-20T14:00:00+00:00 EmrCreateJobFlowOperator 2023-06-20T15:00:38.527641+00:00 2023-06-20T15:00:39.347953+00:00 0:00:00.820312 395087 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-20T15:00:36.575498+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-20T14:00:00+00:00 PythonOperator 2023-06-20T15:00:18.485178+00:00 2023-06-20T15:00:19.429418+00:00 0:00:00.944240 395085 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-20T15:00:16.559343+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-20T13:00:00+00:00 TriggerDagRunOperator 2023-06-20T14:10:54.341848+00:00 2023-06-20T14:10:54.805862+00:00 0:00:00.464014 395072 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-20T14:10:52.097517+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-20T13:00:00+00:00 TriggerDagRunOperator 2023-06-20T14:10:54.104768+00:00 2023-06-20T14:10:54.518933+00:00 0:00:00.414165 395071 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-20T14:10:52.097551+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-20T13:00:00+00:00 EmrJobFlowSensor 2023-06-20T14:00:46.437297+00:00 2023-06-20T14:10:48.135906+00:00 0:10:01.698609 395065 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-20T14:00:44.440352+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-20T13:00:00+00:00 EmrCreateJobFlowOperator 2023-06-20T14:00:24.643997+00:00 2023-06-20T14:00:25.585108+00:00 0:00:00.941111 395063 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-20T14:00:22.373540+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-20T13:00:00+00:00 PythonOperator 2023-06-20T14:00:04.358638+00:00 2023-06-20T14:00:05.197163+00:00 0:00:00.838525 395061 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-20T14:00:02.355198+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-20T12:00:00+00:00 TriggerDagRunOperator 2023-06-20T13:11:40.607068+00:00 2023-06-20T13:11:41.110691+00:00 0:00:00.503623 395048 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-20T13:11:38.198742+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-20T12:00:00+00:00 TriggerDagRunOperator 2023-06-20T13:11:40.225434+00:00 2023-06-20T13:11:40.635704+00:00 0:00:00.410270 395047 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-20T13:11:38.198767+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-20T12:00:00+00:00 EmrJobFlowSensor 2023-06-20T13:01:24.959719+00:00 2023-06-20T13:11:26.573724+00:00 0:10:01.614005 395041 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-20T13:01:23.006208+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-20T12:00:00+00:00 EmrCreateJobFlowOperator 2023-06-20T13:01:03.322646+00:00 2023-06-20T13:01:04.386716+00:00 0:00:01.064070 395039 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-20T13:01:00.998230+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-20T12:00:00+00:00 PythonOperator 2023-06-20T13:00:42.999047+00:00 2023-06-20T13:00:43.862856+00:00 0:00:00.863809 395037 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-20T13:00:40.988473+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-20T11:00:00+00:00 TriggerDagRunOperator 2023-06-20T12:11:08.704728+00:00 2023-06-20T12:11:09.212350+00:00 0:00:00.507622 395019 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-20T12:11:06.117988+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-20T11:00:00+00:00 TriggerDagRunOperator 2023-06-20T12:11:08.308394+00:00 2023-06-20T12:11:08.706013+00:00 0:00:00.397619 395018 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-20T12:11:06.117957+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-20T11:00:00+00:00 EmrJobFlowSensor 2023-06-20T12:00:59.234419+00:00 2023-06-20T12:11:00.988564+00:00 0:10:01.754145 395010 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-20T12:00:57.245499+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-20T11:00:00+00:00 EmrCreateJobFlowOperator 2023-06-20T12:00:39.380816+00:00 2023-06-20T12:00:40.341773+00:00 0:00:00.960957 395008 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-20T12:00:37.202813+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-20T11:00:00+00:00 PythonOperator 2023-06-20T12:00:17.158887+00:00 2023-06-20T12:00:18.082564+00:00 0:00:00.923677 395006 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-20T12:00:15.182270+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-20T10:00:00+00:00 TriggerDagRunOperator 2023-06-20T11:11:10.356296+00:00 2023-06-20T11:11:10.815020+00:00 0:00:00.458724 394993 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-20T11:11:08.056383+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-20T10:00:00+00:00 TriggerDagRunOperator 2023-06-20T11:11:10.127813+00:00 2023-06-20T11:11:10.517330+00:00 0:00:00.389517 394992 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-20T11:11:08.056408+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-20T10:00:00+00:00 EmrJobFlowSensor 2023-06-20T11:00:59.243660+00:00 2023-06-20T11:11:00.891874+00:00 0:10:01.648214 394984 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-20T11:00:57.358350+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-20T10:00:00+00:00 EmrCreateJobFlowOperator 2023-06-20T11:00:39.577579+00:00 2023-06-20T11:00:40.586736+00:00 0:00:01.009157 394982 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-20T11:00:37.337292+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-20T10:00:00+00:00 PythonOperator 2023-06-20T11:00:17.497004+00:00 2023-06-20T11:00:18.460221+00:00 0:00:00.963217 394980 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-20T11:00:15.320131+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-20T09:00:00+00:00 TriggerDagRunOperator 2023-06-20T10:11:17.984057+00:00 2023-06-20T10:11:18.444807+00:00 0:00:00.460750 394961 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-20T10:11:15.754681+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-20T09:00:00+00:00 TriggerDagRunOperator 2023-06-20T10:11:17.805374+00:00 2023-06-20T10:11:18.219563+00:00 0:00:00.414189 394960 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-20T10:11:15.754708+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-20T09:00:00+00:00 EmrJobFlowSensor 2023-06-20T10:01:05.133787+00:00 2023-06-20T10:11:06.957323+00:00 0:10:01.823536 394953 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-20T10:01:02.824900+00:00 2 default_pool