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-19T13:00:00+00:00 EmrCreateJobFlowOperator 2023-06-19T14:00:31.928894+00:00 2023-06-19T14:00:32.843294+00:00 0:00:00.914400 394465 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-19T14:00:29.848225+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-19T13:00:00+00:00 PythonOperator 2023-06-19T14:00:12.088957+00:00 2023-06-19T14:00:13.046269+00:00 0:00:00.957312 394463 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-19T14:00:09.817988+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-19T12:00:00+00:00 TriggerDagRunOperator 2023-06-19T13:16:33.016411+00:00 2023-06-19T13:16:33.473917+00:00 0:00:00.457506 394453 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-19T13:16:30.534226+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-19T12:00:00+00:00 TriggerDagRunOperator 2023-06-19T13:16:32.676848+00:00 2023-06-19T13:16:33.132359+00:00 0:00:00.455511 394452 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-19T13:16:30.534198+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-19T12:00:00+00:00 EmrJobFlowSensor 2023-06-19T13:06:05.349262+00:00 2023-06-19T13:16:07.385709+00:00 0:10:02.036447 394447 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-19T13:06:03.097723+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-19T12:00:00+00:00 EmrCreateJobFlowOperator 2023-06-19T13:05:45.387860+00:00 2023-06-19T13:05:46.464534+00:00 0:00:01.076674 394444 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-19T13:05:43.076279+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-19T12:00:00+00:00 PythonOperator 2023-06-19T13:05:23.292702+00:00 2023-06-19T13:05:24.169907+00:00 0:00:00.877205 394441 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-19T13:05:21.114675+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-19T11:00:00+00:00 TriggerDagRunOperator 2023-06-19T12:10:28.680176+00:00 2023-06-19T12:10:29.134854+00:00 0:00:00.454678 394431 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-19T12:10:26.154428+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-19T11:00:00+00:00 TriggerDagRunOperator 2023-06-19T12:10:28.404300+00:00 2023-06-19T12:10:28.810907+00:00 0:00:00.406607 394430 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-19T12:10:26.154401+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-19T11:00:00+00:00 EmrJobFlowSensor 2023-06-19T12:03:21.975154+00:00 2023-06-19T12:10:23.377072+00:00 0:07:01.401918 394425 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-19T12:03:20.078093+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-19T11:00:00+00:00 EmrCreateJobFlowOperator 2023-06-19T12:00:33.938542+00:00 2023-06-19T12:00:34.879522+00:00 0:00:00.940980 394421 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-19T12:00:32.029527+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-19T11:00:00+00:00 PythonOperator 2023-06-19T12:00:11.957951+00:00 2023-06-19T12:00:12.827554+00:00 0:00:00.869603 394419 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-19T12:00:09.992334+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-19T10:00:00+00:00 TriggerDagRunOperator 2023-06-19T11:13:11.614252+00:00 2023-06-19T11:13:12.082115+00:00 0:00:00.467863 394408 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-19T11:13:09.362581+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-19T10:00:00+00:00 TriggerDagRunOperator 2023-06-19T11:13:11.304487+00:00 2023-06-19T11:13:11.695417+00:00 0:00:00.390930 394407 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-19T11:13:09.362550+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-19T10:00:00+00:00 EmrJobFlowSensor 2023-06-19T11:12:51.390057+00:00 2023-06-19T11:12:51.894158+00:00 0:00:00.504101 394406 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-19T11:12:49.342157+00:00 3 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-19T10:00:00+00:00 EmrCreateJobFlowOperator 2023-06-19T11:00:45.295117+00:00 2023-06-19T11:00:46.387108+00:00 0:00:01.091991 394397 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-19T11:00:43.214084+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-19T10:00:00+00:00 PythonOperator 2023-06-19T11:00:25.446098+00:00 2023-06-19T11:00:26.415942+00:00 0:00:00.969844 394395 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-19T11:00:23.195061+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-19T09:00:00+00:00 TriggerDagRunOperator 2023-06-19T10:14:43.901964+00:00 2023-06-19T10:14:44.379090+00:00 0:00:00.477126 394386 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-19T10:14:41.440397+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-19T09:00:00+00:00 TriggerDagRunOperator 2023-06-19T10:14:43.615951+00:00 2023-06-19T10:14:44.013832+00:00 0:00:00.397881 394385 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-19T10:14:41.440423+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-19T09:00:00+00:00 EmrJobFlowSensor 2023-06-19T10:04:27.063927+00:00 2023-06-19T10:14:28.754560+00:00 0:10:01.690633 394379 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-19T10:04:25.175728+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-19T09:00:00+00:00 EmrCreateJobFlowOperator 2023-06-19T10:04:05.700058+00:00 2023-06-19T10:04:06.604997+00:00 0:00:00.904939 394377 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-19T10:04:03.153138+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-19T09:00:00+00:00 PythonOperator 2023-06-19T10:03:45.444267+00:00 2023-06-19T10:03:46.342071+00:00 0:00:00.897804 394375 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-19T10:03:43.136686+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-19T08:00:00+00:00 TriggerDagRunOperator 2023-06-19T09:20:21.648241+00:00 2023-06-19T09:20:22.137375+00:00 0:00:00.489134 394365 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-19T09:20:19.170677+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-19T08:00:00+00:00 TriggerDagRunOperator 2023-06-19T09:20:21.313810+00:00 2023-06-19T09:20:21.738119+00:00 0:00:00.424309 394364 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-19T09:20:19.170649+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-19T08:00:00+00:00 EmrJobFlowSensor 2023-06-19T09:07:32.211878+00:00 2023-06-19T09:17:34.186322+00:00 0:10:01.974444 394358 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-19T09:07:29.991967+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-19T08:00:00+00:00 EmrCreateJobFlowOperator 2023-06-19T09:07:12.254555+00:00 2023-06-19T09:07:13.269852+00:00 0:00:01.015297 394355 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-19T09:07:09.975617+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-19T08:00:00+00:00 PythonOperator 2023-06-19T09:00:11.214445+00:00 2023-06-19T09:00:12.070589+00:00 0:00:00.856144 394352 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-19T09:00:08.837038+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-19T07:00:00+00:00 TriggerDagRunOperator 2023-06-19T08:11:20.699131+00:00 2023-06-19T08:11:21.226926+00:00 0:00:00.527795 394343 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-19T08:11:18.237727+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-19T07:00:00+00:00 TriggerDagRunOperator 2023-06-19T08:11:20.363258+00:00 2023-06-19T08:11:20.748759+00:00 0:00:00.385501 394342 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-19T08:11:18.237700+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-19T07:00:00+00:00 EmrJobFlowSensor 2023-06-19T08:01:07.694381+00:00 2023-06-19T08:11:09.614844+00:00 0:10:01.920463 394335 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-19T08:01:05.412643+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-19T07:00:00+00:00 EmrCreateJobFlowOperator 2023-06-19T08:00:45.674059+00:00 2023-06-19T08:00:46.679630+00:00 0:00:01.005571 394333 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-19T08:00:43.391325+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-19T07:00:00+00:00 PythonOperator 2023-06-19T08:00:25.300335+00:00 2023-06-19T08:00:26.133742+00:00 0:00:00.833407 394331 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-19T08:00:23.372032+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-19T06:00:00+00:00 TriggerDagRunOperator 2023-06-19T07:44:13.406770+00:00 2023-06-19T07:44:13.874020+00:00 0:00:00.467250 394324 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-19T07:44:10.921700+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-19T06:00:00+00:00 TriggerDagRunOperator 2023-06-19T07:44:13.136336+00:00 2023-06-19T07:44:13.532689+00:00 0:00:00.396353 394323 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-19T07:44:10.921673+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-19T06:00:00+00:00 EmrJobFlowSensor 2023-06-19T07:33:49.313520+00:00 2023-06-19T07:43:51.391340+00:00 0:10:02.077820 394321 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-19T07:33:47.309711+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-19T06:00:00+00:00 EmrCreateJobFlowOperator 2023-06-19T07:33:27.547891+00:00 2023-06-19T07:33:28.539225+00:00 0:00:00.991334 394320 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-19T07:33:25.286646+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-19T06:00:00+00:00 PythonOperator 2023-06-19T07:33:07.304944+00:00 2023-06-19T07:33:08.234926+00:00 0:00:00.929982 394319 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-19T07:33:05.266426+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-08T14:00:00+00:00 TriggerDagRunOperator 2023-06-08T15:11:41.116276+00:00 2023-06-08T15:11:41.448146+00:00 0:00:00.331870 393130 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-08T15:11:38.732764+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-08T14:00:00+00:00 TriggerDagRunOperator 2023-06-08T15:11:40.924597+00:00 2023-06-08T15:11:41.400166+00:00 0:00:00.475569 393129 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-08T15:11:38.732792+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-08T14:00:00+00:00 EmrJobFlowSensor 2023-06-08T15:01:16.205086+00:00 2023-06-08T15:11:17.904228+00:00 0:10:01.699142 393122 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-08T15:01:14.044024+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-08T14:00:00+00:00 EmrCreateJobFlowOperator 2023-06-08T15:00:54.263905+00:00 2023-06-08T15:00:55.156393+00:00 0:00:00.892488 393120 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-08T15:00:52.024017+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-08T14:00:00+00:00 PythonOperator 2023-06-08T15:00:34.351075+00:00 2023-06-08T15:00:35.215258+00:00 0:00:00.864183 393118 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-08T15:00:32.005591+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-08T13:00:00+00:00 TriggerDagRunOperator 2023-06-08T14:13:29.262615+00:00 2023-06-08T14:13:29.619043+00:00 0:00:00.356428 393108 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-08T14:13:26.920131+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-08T13:00:00+00:00 TriggerDagRunOperator 2023-06-08T14:13:29.134100+00:00 2023-06-08T14:13:29.573405+00:00 0:00:00.439305 393107 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-08T14:13:26.920160+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-08T13:00:00+00:00 EmrJobFlowSensor 2023-06-08T14:03:21.922023+00:00 2023-06-08T14:13:23.650088+00:00 0:10:01.728065 393101 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-08T14:03:19.323128+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-08T13:00:00+00:00 EmrCreateJobFlowOperator 2023-06-08T14:03:01.368196+00:00 2023-06-08T14:03:02.468697+00:00 0:00:01.100501 393099 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-08T14:02:59.303295+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-08T13:00:00+00:00 PythonOperator 2023-06-08T14:02:39.607204+00:00 2023-06-08T14:02:40.413334+00:00 0:00:00.806130 393097 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-08T14:02:37.297000+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-08T12:00:00+00:00 TriggerDagRunOperator 2023-06-08T13:17:34.774307+00:00 2023-06-08T13:17:35.129516+00:00 0:00:00.355209 393087 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-08T13:17:32.412359+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-08T12:00:00+00:00 TriggerDagRunOperator 2023-06-08T13:17:34.564168+00:00 2023-06-08T13:17:35.033220+00:00 0:00:00.469052 393086 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-08T13:17:32.412330+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-08T12:00:00+00:00 EmrJobFlowSensor 2023-06-08T13:07:28.788481+00:00 2023-06-08T13:17:30.526118+00:00 0:10:01.737637 393083 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-08T13:07:26.837071+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-08T12:00:00+00:00 EmrCreateJobFlowOperator 2023-06-08T13:07:08.881133+00:00 2023-06-08T13:07:09.848118+00:00 0:00:00.966985 393080 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-08T13:07:06.819763+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-08T12:00:00+00:00 PythonOperator 2023-06-08T13:06:46.985451+00:00 2023-06-08T13:06:47.789580+00:00 0:00:00.804129 393077 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-08T13:06:44.797086+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-08T11:00:00+00:00 TriggerDagRunOperator 2023-06-08T12:14:14.144546+00:00 2023-06-08T12:14:14.477059+00:00 0:00:00.332513 393065 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-08T12:14:11.705625+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-08T11:00:00+00:00 TriggerDagRunOperator 2023-06-08T12:14:14.003224+00:00 2023-06-08T12:14:14.438670+00:00 0:00:00.435446 393064 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-08T12:14:11.705596+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-08T11:00:00+00:00 EmrJobFlowSensor 2023-06-08T12:03:55.600995+00:00 2023-06-08T12:13:57.325942+00:00 0:10:01.724947 393058 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-08T12:03:53.321394+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-08T11:00:00+00:00 EmrCreateJobFlowOperator 2023-06-08T12:03:33.286500+00:00 2023-06-08T12:03:34.241395+00:00 0:00:00.954895 393055 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-08T12:03:31.300643+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-08T11:00:00+00:00 PythonOperator 2023-06-08T12:03:13.342115+00:00 2023-06-08T12:03:14.316075+00:00 0:00:00.973960 393054 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-08T12:03:11.283605+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-08T10:00:00+00:00 TriggerDagRunOperator 2023-06-08T11:12:37.351190+00:00 2023-06-08T11:12:37.681447+00:00 0:00:00.330257 393042 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-08T11:12:34.720750+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-08T10:00:00+00:00 TriggerDagRunOperator 2023-06-08T11:12:37.211322+00:00 2023-06-08T11:12:37.647433+00:00 0:00:00.436111 393041 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-08T11:12:34.720717+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-08T10:00:00+00:00 EmrJobFlowSensor 2023-06-08T11:00:47.010985+00:00 2023-06-08T11:10:48.870762+00:00 0:10:01.859777 393035 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-08T11:00:44.801663+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-08T10:00:00+00:00 EmrCreateJobFlowOperator 2023-06-08T11:00:27.099110+00:00 2023-06-08T11:00:27.886540+00:00 0:00:00.787430 393033 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-08T11:00:24.806392+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-08T10:00:00+00:00 PythonOperator 2023-06-08T11:00:05.117506+00:00 2023-06-08T11:00:05.996604+00:00 0:00:00.879098 393031 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-08T11:00:02.747015+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-08T09:00:00+00:00 TriggerDagRunOperator 2023-06-08T10:11:26.204248+00:00 2023-06-08T10:11:26.559466+00:00 0:00:00.355218 393022 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-08T10:11:23.724592+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-08T09:00:00+00:00 TriggerDagRunOperator 2023-06-08T10:11:26.047439+00:00 2023-06-08T10:11:26.479088+00:00 0:00:00.431649 393021 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-08T10:11:23.724620+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-08T09:00:00+00:00 EmrJobFlowSensor 2023-06-08T10:01:04.959050+00:00 2023-06-08T10:11:06.866649+00:00 0:10:01.907599 393014 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-08T10:01:02.752874+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-08T09:00:00+00:00 EmrCreateJobFlowOperator 2023-06-08T10:00:43.733962+00:00 2023-06-08T10:00:44.506186+00:00 0:00:00.772224 393012 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-08T10:00:40.733553+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-08T09:00:00+00:00 PythonOperator 2023-06-08T10:00:22.691601+00:00 2023-06-08T10:00:23.687959+00:00 0:00:00.996358 393010 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-08T10:00:20.717120+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-08T08:00:00+00:00 TriggerDagRunOperator 2023-06-08T09:11:15.140018+00:00 2023-06-08T09:11:15.478049+00:00 0:00:00.338031 393001 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-08T09:11:12.882596+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-08T08:00:00+00:00 TriggerDagRunOperator 2023-06-08T09:11:14.887134+00:00 2023-06-08T09:11:15.378858+00:00 0:00:00.491724 393000 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-08T09:11:12.882568+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-08T08:00:00+00:00 EmrJobFlowSensor 2023-06-08T09:00:58.723164+00:00 2023-06-08T09:11:00.505500+00:00 0:10:01.782336 392994 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-08T09:00:56.720541+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-08T08:00:00+00:00 EmrCreateJobFlowOperator 2023-06-08T09:00:36.781987+00:00 2023-06-08T09:00:37.684310+00:00 0:00:00.902323 392992 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-08T09:00:34.699882+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-08T08:00:00+00:00 PythonOperator 2023-06-08T09:00:15.304257+00:00 2023-06-08T09:00:16.095075+00:00 0:00:00.790818 392990 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-08T09:00:12.658293+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-08T07:00:00+00:00 TriggerDagRunOperator 2023-06-08T08:11:13.128388+00:00 2023-06-08T08:11:13.512423+00:00 0:00:00.384035 392980 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-08T08:11:10.703442+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-08T07:00:00+00:00 TriggerDagRunOperator 2023-06-08T08:11:12.881950+00:00 2023-06-08T08:11:13.427415+00:00 0:00:00.545465 392979 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-08T08:11:10.703411+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-08T07:00:00+00:00 EmrJobFlowSensor 2023-06-08T08:00:49.398037+00:00 2023-06-08T08:10:51.161749+00:00 0:10:01.763712 392972 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-08T08:00:47.341630+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-08T07:00:00+00:00 EmrCreateJobFlowOperator 2023-06-08T08:00:29.526281+00:00 2023-06-08T08:00:30.338704+00:00 0:00:00.812423 392970 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-08T08:00:27.321075+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-08T07:00:00+00:00 PythonOperator 2023-06-08T08:00:07.747832+00:00 2023-06-08T08:00:08.587022+00:00 0:00:00.839190 392968 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-08T08:00:05.300823+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-08T06:00:00+00:00 TriggerDagRunOperator 2023-06-08T07:19:46.521836+00:00 2023-06-08T07:19:46.866995+00:00 0:00:00.345159 392960 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-08T07:19:43.875578+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-08T06:00:00+00:00 TriggerDagRunOperator 2023-06-08T07:19:46.209258+00:00 2023-06-08T07:19:46.650517+00:00 0:00:00.441259 392959 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-08T07:19:43.875626+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-08T06:00:00+00:00 EmrJobFlowSensor 2023-06-08T07:07:41.715535+00:00 2023-06-08T07:17:43.916118+00:00 0:10:02.200583 392954 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-08T07:07:39.449186+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-08T06:00:00+00:00 EmrCreateJobFlowOperator 2023-06-08T07:07:21.758001+00:00 2023-06-08T07:07:22.656432+00:00 0:00:00.898431 392952 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-08T07:07:19.434065+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-08T06:00:00+00:00 PythonOperator 2023-06-08T07:00:18.758838+00:00 2023-06-08T07:00:19.592125+00:00 0:00:00.833287 392947 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-08T07:00:16.304537+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-08T05:00:00+00:00 TriggerDagRunOperator 2023-06-08T06:11:12.703581+00:00 2023-06-08T06:11:13.208667+00:00 0:00:00.505086 392938 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-08T06:11:10.327018+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-08T05:00:00+00:00 TriggerDagRunOperator 2023-06-08T06:11:12.676030+00:00 2023-06-08T06:11:13.266442+00:00 0:00:00.590412 392937 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-08T06:11:10.326988+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-08T05:00:00+00:00 EmrJobFlowSensor 2023-06-08T06:00:52.355077+00:00 2023-06-08T06:10:54.122964+00:00 0:10:01.767887 392930 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-08T06:00:50.138937+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-08T05:00:00+00:00 EmrCreateJobFlowOperator 2023-06-08T06:00:32.357862+00:00 2023-06-08T06:00:33.121122+00:00 0:00:00.763260 392929 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-08T06:00:30.119219+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-08T05:00:00+00:00 PythonOperator 2023-06-08T06:00:10.272540+00:00 2023-06-08T06:00:11.234208+00:00 0:00:00.961668 392926 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-08T06:00:08.096008+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-08T04:00:00+00:00 TriggerDagRunOperator 2023-06-08T05:11:20.231910+00:00 2023-06-08T05:11:20.564151+00:00 0:00:00.332241 392915 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-08T05:11:18.009788+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-08T04:00:00+00:00 TriggerDagRunOperator 2023-06-08T05:11:20.047825+00:00 2023-06-08T05:11:20.486755+00:00 0:00:00.438930 392914 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-08T05:11:18.009818+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-08T04:00:00+00:00 EmrJobFlowSensor 2023-06-08T05:00:59.345535+00:00 2023-06-08T05:11:01.333245+00:00 0:10:01.987710 392907 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-08T05:00:57.211300+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-08T04:00:00+00:00 EmrCreateJobFlowOperator 2023-06-08T05:00:39.209583+00:00 2023-06-08T05:00:40.088606+00:00 0:00:00.879023 392906 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-08T05:00:37.192456+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-08T04:00:00+00:00 PythonOperator 2023-06-08T05:00:17.684354+00:00 2023-06-08T05:00:18.543297+00:00 0:00:00.858943 392904 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-08T05:00:15.172647+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-08T03:00:00+00:00 TriggerDagRunOperator 2023-06-08T04:20:00.106346+00:00 2023-06-08T04:20:00.553753+00:00 0:00:00.447407 392894 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-08T04:19:57.469626+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-08T03:00:00+00:00 TriggerDagRunOperator 2023-06-08T04:19:59.863191+00:00 2023-06-08T04:20:00.429254+00:00 0:00:00.566063 392893 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-08T04:19:57.469589+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-08T03:00:00+00:00 EmrJobFlowSensor 2023-06-08T04:01:36.809534+00:00 2023-06-08T04:11:38.645392+00:00 0:10:01.835858 392887 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-08T04:01:34.317950+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-08T03:00:00+00:00 EmrCreateJobFlowOperator 2023-06-08T04:01:16.437925+00:00 2023-06-08T04:01:17.291046+00:00 0:00:00.853121 392885 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-08T04:01:14.298356+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-08T03:00:00+00:00 PythonOperator 2023-06-08T04:00:12.753036+00:00 2023-06-08T04:00:13.617164+00:00 0:00:00.864128 392881 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-08T04:00:10.429261+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-08T02:00:00+00:00 TriggerDagRunOperator 2023-06-08T03:12:31.144902+00:00 2023-06-08T03:12:31.509675+00:00 0:00:00.364773 392871 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-08T03:12:28.790404+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-08T02:00:00+00:00 TriggerDagRunOperator 2023-06-08T03:12:31.133535+00:00 2023-06-08T03:12:31.585140+00:00 0:00:00.451605 392870 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-08T03:12:28.790432+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-08T02:00:00+00:00 EmrJobFlowSensor 2023-06-08T03:02:10.765313+00:00 2023-06-08T03:12:12.577992+00:00 0:10:01.812679 392864 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-08T03:02:08.567650+00:00 2 default_pool