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-03T22:00:00+00:00 EmrCreateJobFlowOperator 2023-06-03T23:00:57.807135+00:00 2023-06-03T23:00:58.692011+00:00 0:00:00.884876 390659 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-03T23:00:55.838643+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-03T22:00:00+00:00 PythonOperator 2023-06-03T23:00:36.363975+00:00 2023-06-03T23:00:37.368152+00:00 0:00:01.004177 390656 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-03T23:00:33.823049+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-03T21:00:00+00:00 TriggerDagRunOperator 2023-06-03T22:11:42.624072+00:00 2023-06-03T22:11:43.129259+00:00 0:00:00.505187 390645 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-03T22:11:40.321834+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-03T21:00:00+00:00 TriggerDagRunOperator 2023-06-03T22:11:42.629094+00:00 2023-06-03T22:11:43.160009+00:00 0:00:00.530915 390644 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-03T22:11:40.321862+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-03T21:00:00+00:00 EmrJobFlowSensor 2023-06-03T22:01:21.619329+00:00 2023-06-03T22:11:23.434813+00:00 0:10:01.815484 390638 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-03T22:01:19.598493+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-03T21:00:00+00:00 EmrCreateJobFlowOperator 2023-06-03T22:00:59.542465+00:00 2023-06-03T22:01:00.447451+00:00 0:00:00.904986 390636 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-03T22:00:57.578886+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-03T21:00:00+00:00 PythonOperator 2023-06-03T22:00:39.507270+00:00 2023-06-03T22:00:40.418274+00:00 0:00:00.911004 390634 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-03T22:00:37.560832+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-03T20:00:00+00:00 TriggerDagRunOperator 2023-06-03T21:11:23.597515+00:00 2023-06-03T21:11:24.040401+00:00 0:00:00.442886 390622 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-03T21:11:21.308112+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-03T20:00:00+00:00 TriggerDagRunOperator 2023-06-03T21:11:23.463941+00:00 2023-06-03T21:11:23.897627+00:00 0:00:00.433686 390621 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-03T21:11:21.308084+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-03T20:00:00+00:00 EmrJobFlowSensor 2023-06-03T21:01:14.377343+00:00 2023-06-03T21:11:16.107232+00:00 0:10:01.729889 390614 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-03T21:01:12.213693+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-03T20:00:00+00:00 EmrCreateJobFlowOperator 2023-06-03T21:00:52.213256+00:00 2023-06-03T21:00:53.192167+00:00 0:00:00.978911 390612 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-03T21:00:50.189888+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-03T20:00:00+00:00 PythonOperator 2023-06-03T21:00:32.103057+00:00 2023-06-03T21:00:33.104475+00:00 0:00:01.001418 390611 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-03T21:00:30.176196+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-03T19:00:00+00:00 TriggerDagRunOperator 2023-06-03T20:11:22.713633+00:00 2023-06-03T20:11:23.185743+00:00 0:00:00.472110 390599 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-03T20:11:20.475986+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-03T19:00:00+00:00 TriggerDagRunOperator 2023-06-03T20:11:22.581853+00:00 2023-06-03T20:11:23.032696+00:00 0:00:00.450843 390598 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-03T20:11:20.476015+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-03T19:00:00+00:00 EmrJobFlowSensor 2023-06-03T20:01:13.514299+00:00 2023-06-03T20:11:15.151390+00:00 0:10:01.637091 390591 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-03T20:01:11.526066+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-03T19:00:00+00:00 EmrCreateJobFlowOperator 2023-06-03T20:00:51.485462+00:00 2023-06-03T20:00:52.369744+00:00 0:00:00.884282 390589 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-03T20:00:49.504345+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-03T19:00:00+00:00 PythonOperator 2023-06-03T20:00:31.696552+00:00 2023-06-03T20:00:32.651772+00:00 0:00:00.955220 390587 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-03T20:00:29.539039+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-03T18:00:00+00:00 TriggerDagRunOperator 2023-06-03T19:11:54.738794+00:00 2023-06-03T19:11:55.269617+00:00 0:00:00.530823 390574 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-03T19:11:52.592627+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-03T18:00:00+00:00 TriggerDagRunOperator 2023-06-03T19:11:54.618467+00:00 2023-06-03T19:11:55.118268+00:00 0:00:00.499801 390573 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-03T19:11:52.592656+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-03T18:00:00+00:00 EmrJobFlowSensor 2023-06-03T19:01:29.587887+00:00 2023-06-03T19:11:31.350764+00:00 0:10:01.762877 390566 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-03T19:01:27.578988+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-03T18:00:00+00:00 EmrCreateJobFlowOperator 2023-06-03T19:01:07.534562+00:00 2023-06-03T19:01:08.472231+00:00 0:00:00.937669 390565 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-03T19:01:05.558263+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-03T18:00:00+00:00 PythonOperator 2023-06-03T19:00:46.096611+00:00 2023-06-03T19:00:47.099642+00:00 0:00:01.003031 390563 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-03T19:00:43.540009+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-03T17:00:00+00:00 TriggerDagRunOperator 2023-06-03T18:11:38.626848+00:00 2023-06-03T18:11:39.099499+00:00 0:00:00.472651 390550 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-03T18:11:36.520862+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-03T17:00:00+00:00 TriggerDagRunOperator 2023-06-03T18:11:38.543646+00:00 2023-06-03T18:11:38.988395+00:00 0:00:00.444749 390549 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-03T18:11:36.520893+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-03T17:00:00+00:00 EmrJobFlowSensor 2023-06-03T18:01:16.807813+00:00 2023-06-03T18:11:18.619347+00:00 0:10:01.811534 390542 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-03T18:01:14.762827+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-03T17:00:00+00:00 EmrCreateJobFlowOperator 2023-06-03T18:00:56.747818+00:00 2023-06-03T18:00:57.668433+00:00 0:00:00.920615 390541 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-03T18:00:54.744073+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-03T17:00:00+00:00 PythonOperator 2023-06-03T18:00:34.779530+00:00 2023-06-03T18:00:35.745311+00:00 0:00:00.965781 390540 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-03T18:00:32.726924+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-03T16:00:00+00:00 TriggerDagRunOperator 2023-06-03T17:23:18.697769+00:00 2023-06-03T17:23:19.178222+00:00 0:00:00.480453 390530 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-03T17:23:16.477251+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-03T16:00:00+00:00 TriggerDagRunOperator 2023-06-03T17:23:18.626197+00:00 2023-06-03T17:23:19.072395+00:00 0:00:00.446198 390529 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-03T17:23:16.477278+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-03T16:00:00+00:00 EmrJobFlowSensor 2023-06-03T17:09:57.332696+00:00 2023-06-03T17:19:58.979574+00:00 0:10:01.646878 390524 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-03T17:09:55.329072+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-03T16:00:00+00:00 EmrCreateJobFlowOperator 2023-06-03T17:09:35.343091+00:00 2023-06-03T17:09:36.226263+00:00 0:00:00.883172 390521 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-03T17:09:33.308219+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-03T16:00:00+00:00 PythonOperator 2023-06-03T17:09:13.608096+00:00 2023-06-03T17:09:14.570235+00:00 0:00:00.962139 390518 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-03T17:09:11.341985+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-03T15:00:00+00:00 TriggerDagRunOperator 2023-06-03T16:11:24.654132+00:00 2023-06-03T16:11:25.110461+00:00 0:00:00.456329 390510 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-03T16:11:22.515348+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-03T15:00:00+00:00 TriggerDagRunOperator 2023-06-03T16:11:24.516226+00:00 2023-06-03T16:11:24.988176+00:00 0:00:00.471950 390509 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-03T16:11:22.515315+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-03T15:00:00+00:00 EmrJobFlowSensor 2023-06-03T16:01:05.790338+00:00 2023-06-03T16:11:07.641741+00:00 0:10:01.851403 390503 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-03T16:01:03.779850+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-03T15:00:00+00:00 EmrCreateJobFlowOperator 2023-06-03T16:00:45.810237+00:00 2023-06-03T16:00:47.076513+00:00 0:00:01.266276 390501 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-03T16:00:43.761623+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-03T15:00:00+00:00 PythonOperator 2023-06-03T16:00:23.863435+00:00 2023-06-03T16:00:24.786718+00:00 0:00:00.923283 390499 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-03T16:00:21.741601+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-03T14:00:00+00:00 TriggerDagRunOperator 2023-06-03T15:16:17.611309+00:00 2023-06-03T15:16:18.045179+00:00 0:00:00.433870 390488 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-03T15:16:15.340606+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-03T14:00:00+00:00 TriggerDagRunOperator 2023-06-03T15:16:17.580604+00:00 2023-06-03T15:16:18.048470+00:00 0:00:00.467866 390487 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-03T15:16:15.340633+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-03T14:00:00+00:00 EmrJobFlowSensor 2023-06-03T15:05:53.219973+00:00 2023-06-03T15:15:54.784524+00:00 0:10:01.564551 390482 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-03T15:05:51.169384+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-03T14:00:00+00:00 EmrCreateJobFlowOperator 2023-06-03T15:05:33.980247+00:00 2023-06-03T15:05:34.899224+00:00 0:00:00.918977 390480 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-03T15:05:31.126352+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-03T14:00:00+00:00 PythonOperator 2023-06-03T15:05:11.642947+00:00 2023-06-03T15:05:12.632141+00:00 0:00:00.989194 390477 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-03T15:05:09.164967+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-03T13:00:00+00:00 TriggerDagRunOperator 2023-06-03T14:51:51.699356+00:00 2023-06-03T14:51:52.160834+00:00 0:00:00.461478 390471 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-03T14:51:49.231065+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-03T13:00:00+00:00 TriggerDagRunOperator 2023-06-03T14:51:51.655078+00:00 2023-06-03T14:51:52.178709+00:00 0:00:00.523631 390470 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-03T14:51:49.231037+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-03T13:00:00+00:00 EmrJobFlowSensor 2023-06-03T14:20:55.367943+00:00 2023-06-03T14:30:57.282022+00:00 0:10:01.914079 390465 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-03T14:20:53.347901+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-03T13:00:00+00:00 EmrCreateJobFlowOperator 2023-06-03T14:20:35.333103+00:00 2023-06-03T14:20:36.243083+00:00 0:00:00.909980 390462 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-03T14:20:33.330531+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-03T13:00:00+00:00 PythonOperator 2023-06-03T14:20:14.182540+00:00 2023-06-03T14:20:15.773309+00:00 0:00:01.590769 390459 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-03T14:20:11.315443+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-03T12:00:00+00:00 TriggerDagRunOperator 2023-06-03T13:11:14.155405+00:00 2023-06-03T13:11:14.600075+00:00 0:00:00.444670 390449 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-03T13:11:11.933522+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-03T12:00:00+00:00 TriggerDagRunOperator 2023-06-03T13:11:14.133859+00:00 2023-06-03T13:11:14.565336+00:00 0:00:00.431477 390448 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-03T13:11:11.933493+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-03T12:00:00+00:00 EmrJobFlowSensor 2023-06-03T13:01:02.813752+00:00 2023-06-03T13:11:04.675024+00:00 0:10:01.861272 390441 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-03T13:01:00.604105+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-03T12:00:00+00:00 EmrCreateJobFlowOperator 2023-06-03T13:00:40.775972+00:00 2023-06-03T13:00:41.738125+00:00 0:00:00.962153 390439 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-03T13:00:38.602055+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-03T12:00:00+00:00 PythonOperator 2023-06-03T13:00:21.054339+00:00 2023-06-03T13:00:22.029571+00:00 0:00:00.975232 390438 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-03T13:00:18.593494+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-03T11:00:00+00:00 TriggerDagRunOperator 2023-06-03T12:11:18.208640+00:00 2023-06-03T12:11:18.644973+00:00 0:00:00.436333 390427 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-03T12:11:16.100305+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-03T11:00:00+00:00 TriggerDagRunOperator 2023-06-03T12:11:18.150448+00:00 2023-06-03T12:11:18.604142+00:00 0:00:00.453694 390426 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-03T12:11:16.100271+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-03T11:00:00+00:00 EmrJobFlowSensor 2023-06-03T12:01:06.639694+00:00 2023-06-03T12:11:08.472639+00:00 0:10:01.832945 390417 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-03T12:01:04.635072+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-03T11:00:00+00:00 EmrCreateJobFlowOperator 2023-06-03T12:00:44.639741+00:00 2023-06-03T12:00:45.642941+00:00 0:00:01.003200 390416 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-03T12:00:42.620513+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-03T11:00:00+00:00 PythonOperator 2023-06-03T12:00:24.652341+00:00 2023-06-03T12:00:25.602861+00:00 0:00:00.950520 390415 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-03T12:00:22.595097+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-03T10:00:00+00:00 TriggerDagRunOperator 2023-06-03T11:11:18.244381+00:00 2023-06-03T11:11:18.678496+00:00 0:00:00.434115 390406 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-03T11:11:16.106404+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-03T10:00:00+00:00 TriggerDagRunOperator 2023-06-03T11:11:18.127423+00:00 2023-06-03T11:11:18.560044+00:00 0:00:00.432621 390405 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-03T11:11:16.106375+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-03T10:00:00+00:00 EmrJobFlowSensor 2023-06-03T11:01:05.828495+00:00 2023-06-03T11:11:07.674333+00:00 0:10:01.845838 390396 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-03T11:01:03.696212+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-03T10:00:00+00:00 EmrCreateJobFlowOperator 2023-06-03T11:00:45.855051+00:00 2023-06-03T11:00:47.022101+00:00 0:00:01.167050 390395 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-03T11:00:43.687236+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-03T10:00:00+00:00 PythonOperator 2023-06-03T11:00:23.682061+00:00 2023-06-03T11:00:24.606794+00:00 0:00:00.924733 390394 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-03T11:00:21.607817+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-03T09:00:00+00:00 TriggerDagRunOperator 2023-06-03T10:11:53.024544+00:00 2023-06-03T10:11:53.454328+00:00 0:00:00.429784 390386 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-03T10:11:50.783157+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-03T09:00:00+00:00 TriggerDagRunOperator 2023-06-03T10:11:52.935652+00:00 2023-06-03T10:11:53.351461+00:00 0:00:00.415809 390385 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-03T10:11:50.783130+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-03T09:00:00+00:00 EmrJobFlowSensor 2023-06-03T10:01:41.075836+00:00 2023-06-03T10:11:43.095170+00:00 0:10:02.019334 390378 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-03T10:01:39.076259+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-03T09:00:00+00:00 EmrCreateJobFlowOperator 2023-06-03T10:01:19.095519+00:00 2023-06-03T10:01:20.195357+00:00 0:00:01.099838 390376 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-03T10:01:17.053881+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-03T09:00:00+00:00 PythonOperator 2023-06-03T10:00:59.447441+00:00 2023-06-03T10:01:00.396059+00:00 0:00:00.948618 390374 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-03T10:00:57.039589+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-03T08:00:00+00:00 TriggerDagRunOperator 2023-06-03T09:12:58.566997+00:00 2023-06-03T09:12:59.065806+00:00 0:00:00.498809 390364 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-03T09:12:56.192102+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-03T08:00:00+00:00 TriggerDagRunOperator 2023-06-03T09:12:58.497560+00:00 2023-06-03T09:12:58.934230+00:00 0:00:00.436670 390363 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-03T09:12:56.192131+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-03T08:00:00+00:00 EmrJobFlowSensor 2023-06-03T09:03:47.659062+00:00 2023-06-03T09:12:49.338814+00:00 0:09:01.679752 390356 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-03T09:03:45.649605+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-03T08:00:00+00:00 EmrCreateJobFlowOperator 2023-06-03T09:03:27.637212+00:00 2023-06-03T09:03:28.529520+00:00 0:00:00.892308 390354 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-03T09:03:25.628152+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-03T08:00:00+00:00 PythonOperator 2023-06-03T09:03:05.711745+00:00 2023-06-03T09:03:06.643809+00:00 0:00:00.932064 390352 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-03T09:03:03.609542+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-03T07:00:00+00:00 TriggerDagRunOperator 2023-06-03T08:12:03.589907+00:00 2023-06-03T08:12:04.050638+00:00 0:00:00.460731 390343 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-03T08:12:01.145345+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-03T07:00:00+00:00 TriggerDagRunOperator 2023-06-03T08:12:03.481307+00:00 2023-06-03T08:12:03.886084+00:00 0:00:00.404777 390342 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-03T08:12:01.145317+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-03T07:00:00+00:00 EmrJobFlowSensor 2023-06-03T08:01:42.721666+00:00 2023-06-03T08:11:44.559438+00:00 0:10:01.837772 390336 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-03T08:01:40.527109+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-03T07:00:00+00:00 EmrCreateJobFlowOperator 2023-06-03T08:01:23.337175+00:00 2023-06-03T08:01:24.241638+00:00 0:00:00.904463 390334 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-03T08:01:20.505752+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-03T07:00:00+00:00 PythonOperator 2023-06-03T08:01:00.489823+00:00 2023-06-03T08:01:01.452527+00:00 0:00:00.962704 390332 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-03T08:00:58.484628+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-03T06:00:00+00:00 TriggerDagRunOperator 2023-06-03T07:16:03.402101+00:00 2023-06-03T07:16:03.791089+00:00 0:00:00.388988 390323 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-03T07:16:00.807836+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-03T06:00:00+00:00 TriggerDagRunOperator 2023-06-03T07:16:02.980642+00:00 2023-06-03T07:16:03.423325+00:00 0:00:00.442683 390322 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-03T07:16:00.807809+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-03T06:00:00+00:00 EmrJobFlowSensor 2023-06-03T07:05:38.032548+00:00 2023-06-03T07:15:39.715608+00:00 0:10:01.683060 390317 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-03T07:05:36.049620+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-03T06:00:00+00:00 EmrCreateJobFlowOperator 2023-06-03T07:05:16.044589+00:00 2023-06-03T07:05:17.370790+00:00 0:00:01.326201 390314 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-03T07:05:14.020984+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-03T06:00:00+00:00 PythonOperator 2023-06-03T07:04:54.305178+00:00 2023-06-03T07:04:55.254258+00:00 0:00:00.949080 390311 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-03T07:04:52.003484+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-03T05:00:00+00:00 TriggerDagRunOperator 2023-06-03T06:12:01.770614+00:00 2023-06-03T06:12:02.236144+00:00 0:00:00.465530 390303 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-03T06:11:59.260270+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-03T05:00:00+00:00 TriggerDagRunOperator 2023-06-03T06:12:01.712059+00:00 2023-06-03T06:12:02.133403+00:00 0:00:00.421344 390302 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-03T06:11:59.260236+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-03T05:00:00+00:00 EmrJobFlowSensor 2023-06-03T06:00:55.308566+00:00 2023-06-03T06:10:57.064960+00:00 0:10:01.756394 390294 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-03T06:00:53.204802+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-03T05:00:00+00:00 EmrCreateJobFlowOperator 2023-06-03T06:00:35.135863+00:00 2023-06-03T06:00:36.064077+00:00 0:00:00.928214 390292 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-03T06:00:33.147659+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-03T05:00:00+00:00 PythonOperator 2023-06-03T06:00:13.206205+00:00 2023-06-03T06:00:14.128328+00:00 0:00:00.922123 390290 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-03T06:00:11.130106+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-03T04:00:00+00:00 TriggerDagRunOperator 2023-06-03T05:11:18.331170+00:00 2023-06-03T05:11:18.770244+00:00 0:00:00.439074 390281 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-03T05:11:15.863819+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-03T04:00:00+00:00 TriggerDagRunOperator 2023-06-03T05:11:18.280705+00:00 2023-06-03T05:11:18.696806+00:00 0:00:00.416101 390280 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-03T05:11:15.863789+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-03T04:00:00+00:00 EmrJobFlowSensor 2023-06-03T05:00:56.724778+00:00 2023-06-03T05:10:58.437626+00:00 0:10:01.712848 390274 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-03T05:00:54.698074+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-03T04:00:00+00:00 EmrCreateJobFlowOperator 2023-06-03T05:00:36.661464+00:00 2023-06-03T05:00:37.620344+00:00 0:00:00.958880 390272 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-03T05:00:34.680805+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-03T04:00:00+00:00 PythonOperator 2023-06-03T05:00:14.674914+00:00 2023-06-03T05:00:15.715145+00:00 0:00:01.040231 390270 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-03T05:00:12.660311+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-03T03:00:00+00:00 TriggerDagRunOperator 2023-06-03T04:14:27.358737+00:00 2023-06-03T04:14:27.804333+00:00 0:00:00.445596 390262 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-03T04:14:25.144108+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-03T03:00:00+00:00 TriggerDagRunOperator 2023-06-03T04:14:27.297019+00:00 2023-06-03T04:14:27.707495+00:00 0:00:00.410476 390261 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-03T04:14:25.144067+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-03T03:00:00+00:00 EmrJobFlowSensor 2023-06-03T04:00:58.518340+00:00 2023-06-03T04:11:00.247179+00:00 0:10:01.728839 390254 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-03T04:00:56.600375+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-03T03:00:00+00:00 EmrCreateJobFlowOperator 2023-06-03T04:00:38.622443+00:00 2023-06-03T04:00:39.658096+00:00 0:00:01.035653 390252 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-03T04:00:36.564578+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-03T03:00:00+00:00 PythonOperator 2023-06-03T04:00:16.841620+00:00 2023-06-03T04:00:17.914636+00:00 0:00:01.073016 390250 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-03T04:00:14.550397+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-03T02:00:00+00:00 TriggerDagRunOperator 2023-06-03T03:22:54.538856+00:00 2023-06-03T03:22:55.006508+00:00 0:00:00.467652 390242 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-03T03:22:52.347217+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-03T02:00:00+00:00 TriggerDagRunOperator 2023-06-03T03:22:54.485773+00:00 2023-06-03T03:22:54.892928+00:00 0:00:00.407155 390241 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-03T03:22:52.347189+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-03T02:00:00+00:00 EmrJobFlowSensor 2023-06-03T03:12:42.670242+00:00 2023-06-03T03:22:44.565228+00:00 0:10:01.894986 390238 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-03T03:12:40.522954+00:00 2 default_pool