Task Instances

Reset Filters
  State Dag Id Task Id Execution Date Operator Start Date End Date Duration Job Id Hostname Unixname Priority Weight Queue Queued Dttm Try Number Pool Log Url
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-23T06:00:00+00:00 EmrCreateJobFlowOperator 2023-05-23T07:00:40.319204+00:00 2023-05-23T07:00:41.317034+00:00 0:00:00.997830 384372 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-23T07:00:36.682742+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-23T06:00:00+00:00 PythonOperator 2023-05-23T07:00:17.167848+00:00 2023-05-23T07:00:18.312520+00:00 0:00:01.144672 384370 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-23T07:00:14.610421+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-23T05:00:00+00:00 TriggerDagRunOperator 2023-05-23T06:26:50.956650+00:00 2023-05-23T06:26:51.459058+00:00 0:00:00.502408 384358 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-23T06:26:48.370161+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-23T05:00:00+00:00 TriggerDagRunOperator 2023-05-23T06:26:50.949182+00:00 2023-05-23T06:26:51.484165+00:00 0:00:00.534983 384357 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-23T06:26:48.370132+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-23T05:00:00+00:00 EmrJobFlowSensor 2023-05-23T06:16:27.022455+00:00 2023-05-23T06:26:29.021731+00:00 0:10:01.999276 384352 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-23T06:16:24.702475+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-23T05:00:00+00:00 EmrCreateJobFlowOperator 2023-05-23T06:16:04.947567+00:00 2023-05-23T06:16:05.828484+00:00 0:00:00.880917 384349 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-23T06:16:02.672193+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-23T05:00:00+00:00 PythonOperator 2023-05-23T06:15:45.218406+00:00 2023-05-23T06:15:46.225790+00:00 0:00:01.007384 384346 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-23T06:15:42.648510+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-23T04:00:00+00:00 TriggerDagRunOperator 2023-05-23T05:11:05.222642+00:00 2023-05-23T05:11:05.691005+00:00 0:00:00.468363 384336 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-23T05:11:02.696535+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-23T04:00:00+00:00 TriggerDagRunOperator 2023-05-23T05:11:05.192704+00:00 2023-05-23T05:11:05.648523+00:00 0:00:00.455819 384335 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-23T05:11:02.696487+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-23T04:00:00+00:00 EmrJobFlowSensor 2023-05-23T05:00:52.367640+00:00 2023-05-23T05:10:54.408511+00:00 0:10:02.040871 384328 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-23T05:00:50.124438+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-23T04:00:00+00:00 EmrCreateJobFlowOperator 2023-05-23T05:00:30.711853+00:00 2023-05-23T05:00:31.681911+00:00 0:00:00.970058 384326 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-23T05:00:28.183152+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-23T04:00:00+00:00 PythonOperator 2023-05-23T05:00:10.610568+00:00 2023-05-23T05:00:11.630595+00:00 0:00:01.020027 384324 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-23T05:00:08.042135+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-23T03:00:00+00:00 TriggerDagRunOperator 2023-05-23T04:11:24.516219+00:00 2023-05-23T04:11:25.050447+00:00 0:00:00.534228 384313 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-23T04:11:21.699194+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-23T03:00:00+00:00 TriggerDagRunOperator 2023-05-23T04:11:24.312678+00:00 2023-05-23T04:11:24.770859+00:00 0:00:00.458181 384312 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-23T04:11:21.699223+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-23T03:00:00+00:00 EmrJobFlowSensor 2023-05-23T04:01:07.457903+00:00 2023-05-23T04:11:09.394635+00:00 0:10:01.936732 384305 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-23T04:01:04.984674+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-23T03:00:00+00:00 EmrCreateJobFlowOperator 2023-05-23T04:00:45.356828+00:00 2023-05-23T04:00:46.297228+00:00 0:00:00.940400 384303 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-23T04:00:42.807529+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-23T03:00:00+00:00 PythonOperator 2023-05-23T04:00:25.202362+00:00 2023-05-23T04:00:26.399182+00:00 0:00:01.196820 384301 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-23T04:00:22.798579+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-23T02:00:00+00:00 TriggerDagRunOperator 2023-05-23T03:11:20.347883+00:00 2023-05-23T03:11:20.829271+00:00 0:00:00.481388 384284 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-23T03:11:17.335250+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-23T02:00:00+00:00 TriggerDagRunOperator 2023-05-23T03:11:20.337877+00:00 2023-05-23T03:11:20.797529+00:00 0:00:00.459652 384283 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-23T03:11:17.335281+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-23T02:00:00+00:00 EmrJobFlowSensor 2023-05-23T03:00:53.275119+00:00 2023-05-23T03:10:55.228990+00:00 0:10:01.953871 384279 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-23T03:00:50.963582+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-23T02:00:00+00:00 EmrCreateJobFlowOperator 2023-05-23T03:00:33.258589+00:00 2023-05-23T03:00:34.164378+00:00 0:00:00.905789 384277 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-23T03:00:30.944756+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-23T02:00:00+00:00 PythonOperator 2023-05-23T03:00:11.318638+00:00 2023-05-23T03:00:12.296047+00:00 0:00:00.977409 384275 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-23T03:00:08.927619+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-23T01:00:00+00:00 TriggerDagRunOperator 2023-05-23T02:11:10.861047+00:00 2023-05-23T02:11:11.323021+00:00 0:00:00.461974 384262 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-23T02:11:07.891583+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-23T01:00:00+00:00 TriggerDagRunOperator 2023-05-23T02:11:10.732932+00:00 2023-05-23T02:11:11.208161+00:00 0:00:00.475229 384261 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-23T02:11:07.891539+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-23T01:00:00+00:00 EmrJobFlowSensor 2023-05-23T02:00:55.132478+00:00 2023-05-23T02:10:57.289415+00:00 0:10:02.156937 384255 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-23T02:00:51.205523+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-23T01:00:00+00:00 EmrCreateJobFlowOperator 2023-05-23T02:00:35.130099+00:00 2023-05-23T02:00:36.044216+00:00 0:00:00.914117 384253 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-23T02:00:31.147296+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-23T01:00:00+00:00 PythonOperator 2023-05-23T02:00:11.613098+00:00 2023-05-23T02:00:12.796966+00:00 0:00:01.183868 384251 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-23T02:00:09.194644+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-23T00:00:00+00:00 TriggerDagRunOperator 2023-05-23T01:11:13.643190+00:00 2023-05-23T01:11:14.102837+00:00 0:00:00.459647 384230 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-23T01:11:10.917467+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-23T00:00:00+00:00 TriggerDagRunOperator 2023-05-23T01:11:13.566446+00:00 2023-05-23T01:11:14.056640+00:00 0:00:00.490194 384229 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-23T01:11:10.917438+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-23T00:00:00+00:00 EmrJobFlowSensor 2023-05-23T01:00:56.041526+00:00 2023-05-23T01:10:57.975200+00:00 0:10:01.933674 384222 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-23T01:00:53.498909+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-23T00:00:00+00:00 EmrCreateJobFlowOperator 2023-05-23T01:00:35.961924+00:00 2023-05-23T01:00:36.858572+00:00 0:00:00.896648 384220 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-23T01:00:33.416458+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-23T00:00:00+00:00 PythonOperator 2023-05-23T01:00:14.241848+00:00 2023-05-23T01:00:15.507196+00:00 0:00:01.265348 384219 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-23T01:00:11.401047+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-22T23:00:00+00:00 TriggerDagRunOperator 2023-05-23T00:11:09.018045+00:00 2023-05-23T00:11:09.481788+00:00 0:00:00.463743 384204 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-23T00:11:06.185690+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-22T23:00:00+00:00 TriggerDagRunOperator 2023-05-23T00:11:08.990515+00:00 2023-05-23T00:11:09.483252+00:00 0:00:00.492737 384203 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-23T00:11:06.185646+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-22T23:00:00+00:00 EmrJobFlowSensor 2023-05-23T00:00:51.839711+00:00 2023-05-23T00:10:53.832893+00:00 0:10:01.993182 384197 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-23T00:00:49.397590+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-22T23:00:00+00:00 EmrCreateJobFlowOperator 2023-05-23T00:00:30.904027+00:00 2023-05-23T00:00:31.967801+00:00 0:00:01.063774 384195 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-23T00:00:27.314771+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-22T23:00:00+00:00 PythonOperator 2023-05-23T00:00:09.671170+00:00 2023-05-23T00:00:10.686225+00:00 0:00:01.015055 384193 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-23T00:00:07.301658+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-22T22:00:00+00:00 TriggerDagRunOperator 2023-05-22T23:11:31.559699+00:00 2023-05-22T23:11:31.991626+00:00 0:00:00.431927 384178 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-22T23:11:29.313370+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-22T22:00:00+00:00 TriggerDagRunOperator 2023-05-22T23:11:31.561914+00:00 2023-05-22T23:11:32.051719+00:00 0:00:00.489805 384177 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-22T23:11:29.313335+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-22T22:00:00+00:00 EmrJobFlowSensor 2023-05-22T23:01:07.725793+00:00 2023-05-22T23:11:09.633163+00:00 0:10:01.907370 384171 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-22T23:01:05.066227+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-22T22:00:00+00:00 EmrCreateJobFlowOperator 2023-05-22T23:00:45.349244+00:00 2023-05-22T23:00:46.319753+00:00 0:00:00.970509 384168 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-22T23:00:43.046658+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-22T22:00:00+00:00 PythonOperator 2023-05-22T23:00:23.180146+00:00 2023-05-22T23:00:24.312196+00:00 0:00:01.132050 384165 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-22T23:00:20.935807+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-22T21:00:00+00:00 TriggerDagRunOperator 2023-05-22T22:11:23.901848+00:00 2023-05-22T22:11:24.348438+00:00 0:00:00.446590 384149 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-22T22:11:21.659922+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-22T21:00:00+00:00 TriggerDagRunOperator 2023-05-22T22:11:23.847442+00:00 2023-05-22T22:11:24.326815+00:00 0:00:00.479373 384148 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-22T22:11:21.659961+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-22T21:00:00+00:00 EmrJobFlowSensor 2023-05-22T22:01:04.716954+00:00 2023-05-22T22:11:06.603431+00:00 0:10:01.886477 384142 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-22T22:01:02.444106+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-22T21:00:00+00:00 EmrCreateJobFlowOperator 2023-05-22T22:00:42.862120+00:00 2023-05-22T22:00:43.771710+00:00 0:00:00.909590 384140 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-22T22:00:40.491782+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-22T21:00:00+00:00 PythonOperator 2023-05-22T22:00:21.345610+00:00 2023-05-22T22:00:22.511026+00:00 0:00:01.165416 384138 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-22T22:00:18.418121+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-22T20:00:00+00:00 TriggerDagRunOperator 2023-05-22T21:11:00.482632+00:00 2023-05-22T21:11:00.961413+00:00 0:00:00.478781 384123 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-22T21:10:57.986564+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-22T20:00:00+00:00 TriggerDagRunOperator 2023-05-22T21:11:00.441006+00:00 2023-05-22T21:11:00.955384+00:00 0:00:00.514378 384122 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-22T21:10:57.986612+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-22T20:00:00+00:00 EmrJobFlowSensor 2023-05-22T21:00:49.293790+00:00 2023-05-22T21:10:51.223010+00:00 0:10:01.929220 384115 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-22T21:00:46.915596+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-22T20:00:00+00:00 EmrCreateJobFlowOperator 2023-05-22T21:00:29.377424+00:00 2023-05-22T21:00:30.478273+00:00 0:00:01.100849 384113 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-22T21:00:26.785459+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-22T20:00:00+00:00 PythonOperator 2023-05-22T21:00:07.220066+00:00 2023-05-22T21:00:08.349038+00:00 0:00:01.128972 384111 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-22T21:00:04.735502+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-22T19:00:00+00:00 TriggerDagRunOperator 2023-05-22T20:11:21.493928+00:00 2023-05-22T20:11:21.964330+00:00 0:00:00.470402 384097 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-22T20:11:19.085786+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-22T19:00:00+00:00 TriggerDagRunOperator 2023-05-22T20:11:21.300836+00:00 2023-05-22T20:11:21.736013+00:00 0:00:00.435177 384096 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-22T20:11:19.085813+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-22T19:00:00+00:00 EmrJobFlowSensor 2023-05-22T20:01:04.100811+00:00 2023-05-22T20:11:06.039225+00:00 0:10:01.938414 384089 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-22T20:01:01.779530+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-22T19:00:00+00:00 EmrCreateJobFlowOperator 2023-05-22T20:00:42.071015+00:00 2023-05-22T20:00:43.073290+00:00 0:00:01.002275 384087 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-22T20:00:39.760768+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-22T19:00:00+00:00 PythonOperator 2023-05-22T20:00:20.522379+00:00 2023-05-22T20:00:21.657124+00:00 0:00:01.134745 384085 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-22T20:00:17.787592+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-22T18:00:00+00:00 TriggerDagRunOperator 2023-05-22T19:11:11.931744+00:00 2023-05-22T19:11:12.402098+00:00 0:00:00.470354 384068 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-22T19:11:09.567410+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-22T18:00:00+00:00 TriggerDagRunOperator 2023-05-22T19:11:11.871853+00:00 2023-05-22T19:11:12.327304+00:00 0:00:00.455451 384067 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-22T19:11:09.567441+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-22T18:00:00+00:00 EmrJobFlowSensor 2023-05-22T19:01:04.164412+00:00 2023-05-22T19:11:06.115209+00:00 0:10:01.950797 384061 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-22T19:01:01.830566+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-22T18:00:00+00:00 EmrCreateJobFlowOperator 2023-05-22T19:00:42.116095+00:00 2023-05-22T19:00:43.126876+00:00 0:00:01.010781 384060 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-22T19:00:39.811840+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-22T18:00:00+00:00 PythonOperator 2023-05-22T19:00:20.339913+00:00 2023-05-22T19:00:21.430965+00:00 0:00:01.091052 384058 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-22T19:00:17.746819+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-22T17:00:00+00:00 TriggerDagRunOperator 2023-05-22T18:11:00.734990+00:00 2023-05-22T18:11:01.190336+00:00 0:00:00.455346 384042 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-22T18:10:57.995651+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-22T17:00:00+00:00 TriggerDagRunOperator 2023-05-22T18:11:00.352229+00:00 2023-05-22T18:11:00.836668+00:00 0:00:00.484439 384041 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-22T18:10:57.995678+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-22T17:00:00+00:00 EmrJobFlowSensor 2023-05-22T18:00:50.763089+00:00 2023-05-22T18:10:52.693565+00:00 0:10:01.930476 384034 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-22T18:00:48.404356+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-22T17:00:00+00:00 EmrCreateJobFlowOperator 2023-05-22T18:00:30.636328+00:00 2023-05-22T18:00:31.735947+00:00 0:00:01.099619 384033 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-22T18:00:28.312197+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-22T17:00:00+00:00 PythonOperator 2023-05-22T18:00:08.714001+00:00 2023-05-22T18:00:09.746014+00:00 0:00:01.032013 384031 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-22T18:00:06.241797+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-22T16:00:00+00:00 TriggerDagRunOperator 2023-05-22T17:11:14.857013+00:00 2023-05-22T17:11:15.331854+00:00 0:00:00.474841 384017 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-22T17:11:12.209618+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-22T16:00:00+00:00 TriggerDagRunOperator 2023-05-22T17:11:14.865828+00:00 2023-05-22T17:11:15.352158+00:00 0:00:00.486330 384016 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-22T17:11:12.209665+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-22T16:00:00+00:00 EmrJobFlowSensor 2023-05-22T17:00:49.352491+00:00 2023-05-22T17:10:51.240092+00:00 0:10:01.887601 384007 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-22T17:00:46.893508+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-22T16:00:00+00:00 EmrCreateJobFlowOperator 2023-05-22T17:00:29.276170+00:00 2023-05-22T17:00:30.188749+00:00 0:00:00.912579 384006 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-22T17:00:26.817966+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-22T16:00:00+00:00 PythonOperator 2023-05-22T17:00:07.530887+00:00 2023-05-22T17:00:08.675559+00:00 0:00:01.144672 384004 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-22T17:00:04.806702+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-22T15:00:00+00:00 TriggerDagRunOperator 2023-05-22T16:11:05.903849+00:00 2023-05-22T16:11:06.362892+00:00 0:00:00.459043 383991 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-22T16:11:03.222315+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-22T15:00:00+00:00 TriggerDagRunOperator 2023-05-22T16:11:05.425013+00:00 2023-05-22T16:11:05.870499+00:00 0:00:00.445486 383990 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-22T16:11:03.222285+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-22T15:00:00+00:00 EmrJobFlowSensor 2023-05-22T16:00:54.607123+00:00 2023-05-22T16:10:56.630858+00:00 0:10:02.023735 383984 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-22T16:00:52.194361+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-22T15:00:00+00:00 EmrCreateJobFlowOperator 2023-05-22T16:00:32.531478+00:00 2023-05-22T16:00:33.615276+00:00 0:00:01.083798 383982 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-22T16:00:30.194977+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-22T15:00:00+00:00 PythonOperator 2023-05-22T16:00:12.736015+00:00 2023-05-22T16:00:13.885122+00:00 0:00:01.149107 383980 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-22T16:00:10.066506+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-22T14:00:00+00:00 TriggerDagRunOperator 2023-05-22T15:12:08.454833+00:00 2023-05-22T15:12:09.080917+00:00 0:00:00.626084 383970 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-22T15:12:05.611503+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-22T14:00:00+00:00 TriggerDagRunOperator 2023-05-22T15:12:08.372686+00:00 2023-05-22T15:12:08.944792+00:00 0:00:00.572106 383969 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-22T15:12:05.611530+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-22T14:00:00+00:00 EmrJobFlowSensor 2023-05-22T15:00:58.704201+00:00 2023-05-22T15:11:00.657970+00:00 0:10:01.953769 383961 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-22T15:00:56.387719+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-22T14:00:00+00:00 EmrCreateJobFlowOperator 2023-05-22T15:00:36.574407+00:00 2023-05-22T15:00:37.480223+00:00 0:00:00.905816 383959 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-22T15:00:34.367187+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-22T14:00:00+00:00 PythonOperator 2023-05-22T15:00:17.151596+00:00 2023-05-22T15:00:18.288909+00:00 0:00:01.137313 383957 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-22T15:00:14.358308+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-22T13:00:00+00:00 TriggerDagRunOperator 2023-05-22T14:29:29.416408+00:00 2023-05-22T14:29:30.094530+00:00 0:00:00.678122 383947 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-22T14:29:26.534817+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-22T13:00:00+00:00 TriggerDagRunOperator 2023-05-22T14:29:29.426336+00:00 2023-05-22T14:29:30.175696+00:00 0:00:00.749360 383946 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-22T14:29:26.534852+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-22T13:00:00+00:00 EmrJobFlowSensor 2023-05-22T14:11:28.097872+00:00 2023-05-22T14:21:30.150022+00:00 0:10:02.052150 383943 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-22T14:11:25.914534+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-22T13:00:00+00:00 EmrCreateJobFlowOperator 2023-05-22T14:11:06.066757+00:00 2023-05-22T14:11:07.095769+00:00 0:00:01.029012 383940 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-22T14:11:03.848803+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-22T13:00:00+00:00 PythonOperator 2023-05-22T14:10:46.183052+00:00 2023-05-22T14:10:47.143078+00:00 0:00:00.960026 383937 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-22T14:10:43.833155+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-22T12:00:00+00:00 TriggerDagRunOperator 2023-05-22T13:11:22.442962+00:00 2023-05-22T13:11:22.952746+00:00 0:00:00.509784 383922 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-22T13:11:19.881589+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-22T12:00:00+00:00 TriggerDagRunOperator 2023-05-22T13:11:22.395737+00:00 2023-05-22T13:11:22.899409+00:00 0:00:00.503672 383921 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-22T13:11:19.881539+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-22T12:00:00+00:00 EmrJobFlowSensor 2023-05-22T13:01:15.731608+00:00 2023-05-22T13:11:17.611360+00:00 0:10:01.879752 383914 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-22T13:01:13.464295+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-22T12:00:00+00:00 EmrCreateJobFlowOperator 2023-05-22T13:00:53.958112+00:00 2023-05-22T13:00:55.314311+00:00 0:00:01.356199 383912 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-22T13:00:51.454693+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-22T12:00:00+00:00 PythonOperator 2023-05-22T13:00:34.220666+00:00 2023-05-22T13:00:35.518638+00:00 0:00:01.297972 383910 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-22T13:00:31.318454+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-22T11:00:00+00:00 TriggerDagRunOperator 2023-05-22T12:17:23.515988+00:00 2023-05-22T12:17:24.304249+00:00 0:00:00.788261 383896 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-22T12:17:19.613539+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-22T11:00:00+00:00 TriggerDagRunOperator 2023-05-22T12:17:21.862662+00:00 2023-05-22T12:17:22.287491+00:00 0:00:00.424829 383895 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-22T12:17:19.613507+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-22T11:00:00+00:00 EmrJobFlowSensor 2023-05-22T12:00:47.610551+00:00 2023-05-22T12:10:49.571007+00:00 0:10:01.960456 383890 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-22T12:00:45.276539+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-22T11:00:00+00:00 EmrCreateJobFlowOperator 2023-05-22T12:00:25.567689+00:00 2023-05-22T12:00:26.777605+00:00 0:00:01.209916 383888 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-22T12:00:23.253552+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-22T11:00:00+00:00 PythonOperator 2023-05-22T12:00:06.017106+00:00 2023-05-22T12:00:07.002477+00:00 0:00:00.985371 383887 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-22T12:00:03.165674+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-22T10:00:00+00:00 TriggerDagRunOperator 2023-05-22T11:14:11.766455+00:00 2023-05-22T11:14:12.221445+00:00 0:00:00.454990 383871 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-22T11:14:08.921932+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-22T10:00:00+00:00 TriggerDagRunOperator 2023-05-22T11:14:11.777670+00:00 2023-05-22T11:14:12.260481+00:00 0:00:00.482811 383870 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-22T11:14:08.921896+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-22T10:00:00+00:00 EmrJobFlowSensor 2023-05-22T11:00:59.795601+00:00 2023-05-22T11:11:02.007919+00:00 0:10:02.212318 383867 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-22T11:00:57.358795+00:00 2 default_pool