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-19T22:00:00+00:00 EmrCreateJobFlowOperator 2023-05-19T23:00:37.981349+00:00 2023-05-19T23:00:38.884167+00:00 0:00:00.902818 382364 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-19T23:00:35.769828+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-19T22:00:00+00:00 PythonOperator 2023-05-19T23:00:15.967999+00:00 2023-05-19T23:00:16.944819+00:00 0:00:00.976820 382361 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-19T23:00:13.752815+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-19T21:00:00+00:00 TriggerDagRunOperator 2023-05-19T22:11:22.147540+00:00 2023-05-19T22:11:22.644027+00:00 0:00:00.496487 382346 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-19T22:11:19.317623+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-19T21:00:00+00:00 TriggerDagRunOperator 2023-05-19T22:11:22.136114+00:00 2023-05-19T22:11:22.644112+00:00 0:00:00.507998 382345 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-19T22:11:19.317593+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-19T21:00:00+00:00 EmrJobFlowSensor 2023-05-19T22:01:03.540956+00:00 2023-05-19T22:11:05.640468+00:00 0:10:02.099512 382338 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-19T22:01:01.068796+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-19T21:00:00+00:00 EmrCreateJobFlowOperator 2023-05-19T22:00:43.268021+00:00 2023-05-19T22:00:44.158735+00:00 0:00:00.890714 382336 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-19T22:00:41.050827+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-19T21:00:00+00:00 PythonOperator 2023-05-19T22:00:21.203648+00:00 2023-05-19T22:00:22.329820+00:00 0:00:01.126172 382334 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-19T22:00:19.030914+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-19T20:00:00+00:00 TriggerDagRunOperator 2023-05-19T21:11:12.272946+00:00 2023-05-19T21:11:12.739502+00:00 0:00:00.466556 382320 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-19T21:11:09.593444+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-19T20:00:00+00:00 TriggerDagRunOperator 2023-05-19T21:11:12.234404+00:00 2023-05-19T21:11:12.735964+00:00 0:00:00.501560 382319 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-19T21:11:09.593401+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-19T20:00:00+00:00 EmrJobFlowSensor 2023-05-19T21:00:59.252051+00:00 2023-05-19T21:11:01.377540+00:00 0:10:02.125489 382312 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-19T21:00:56.990163+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-19T20:00:00+00:00 EmrCreateJobFlowOperator 2023-05-19T21:00:39.246247+00:00 2023-05-19T21:00:40.235474+00:00 0:00:00.989227 382310 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-19T21:00:36.970884+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-19T20:00:00+00:00 PythonOperator 2023-05-19T21:00:17.227691+00:00 2023-05-19T21:00:18.334837+00:00 0:00:01.107146 382308 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-19T21:00:14.951048+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-19T19:00:00+00:00 TriggerDagRunOperator 2023-05-19T20:11:16.430237+00:00 2023-05-19T20:11:16.910573+00:00 0:00:00.480336 382293 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-19T20:11:13.688898+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-19T19:00:00+00:00 TriggerDagRunOperator 2023-05-19T20:11:16.411378+00:00 2023-05-19T20:11:16.854563+00:00 0:00:00.443185 382292 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-19T20:11:13.688868+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-19T19:00:00+00:00 EmrJobFlowSensor 2023-05-19T20:01:06.050915+00:00 2023-05-19T20:11:08.235391+00:00 0:10:02.184476 382285 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-19T20:01:03.694195+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-19T19:00:00+00:00 EmrCreateJobFlowOperator 2023-05-19T20:00:46.197385+00:00 2023-05-19T20:00:47.263609+00:00 0:00:01.066224 382283 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-19T20:00:43.587425+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-19T19:00:00+00:00 PythonOperator 2023-05-19T20:00:23.931535+00:00 2023-05-19T20:00:25.092053+00:00 0:00:01.160518 382281 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-19T20:00:21.569173+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-19T18:00:00+00:00 TriggerDagRunOperator 2023-05-19T19:11:29.290088+00:00 2023-05-19T19:11:29.774188+00:00 0:00:00.484100 382265 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-19T19:11:26.788256+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-19T18:00:00+00:00 TriggerDagRunOperator 2023-05-19T19:11:29.293629+00:00 2023-05-19T19:11:29.864640+00:00 0:00:00.571011 382264 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-19T19:11:26.788207+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-19T18:00:00+00:00 EmrJobFlowSensor 2023-05-19T19:01:04.351579+00:00 2023-05-19T19:11:06.320738+00:00 0:10:01.969159 382256 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-19T19:01:01.901931+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-19T18:00:00+00:00 EmrCreateJobFlowOperator 2023-05-19T19:00:44.206303+00:00 2023-05-19T19:00:45.173772+00:00 0:00:00.967469 382255 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-19T19:00:41.805392+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-19T18:00:00+00:00 PythonOperator 2023-05-19T19:00:21.933144+00:00 2023-05-19T19:00:23.005456+00:00 0:00:01.072312 382254 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-19T19:00:19.728390+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-19T17:00:00+00:00 TriggerDagRunOperator 2023-05-19T18:11:11.666844+00:00 2023-05-19T18:11:12.100968+00:00 0:00:00.434124 382238 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-19T18:11:09.303622+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-19T17:00:00+00:00 TriggerDagRunOperator 2023-05-19T18:11:11.641750+00:00 2023-05-19T18:11:12.130680+00:00 0:00:00.488930 382237 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-19T18:11:09.303650+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-19T17:00:00+00:00 EmrJobFlowSensor 2023-05-19T18:00:46.599138+00:00 2023-05-19T18:10:48.539275+00:00 0:10:01.940137 382229 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-19T18:00:44.315078+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-19T17:00:00+00:00 EmrCreateJobFlowOperator 2023-05-19T18:00:26.558118+00:00 2023-05-19T18:00:27.395481+00:00 0:00:00.837363 382228 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-19T18:00:24.235198+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-19T17:00:00+00:00 PythonOperator 2023-05-19T18:00:04.626176+00:00 2023-05-19T18:00:05.748239+00:00 0:00:01.122063 382226 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-19T18:00:02.217674+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-19T16:00:00+00:00 TriggerDagRunOperator 2023-05-19T17:11:30.286037+00:00 2023-05-19T17:11:30.892965+00:00 0:00:00.606928 382213 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-19T17:11:27.627102+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-19T16:00:00+00:00 TriggerDagRunOperator 2023-05-19T17:11:29.945355+00:00 2023-05-19T17:11:30.418715+00:00 0:00:00.473360 382212 airflow-worker-2.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-19T17:11:27.627063+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-19T16:00:00+00:00 EmrJobFlowSensor 2023-05-19T17:01:04.935052+00:00 2023-05-19T17:11:06.845662+00:00 0:10:01.910610 382203 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-19T17:01:02.611817+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-19T16:00:00+00:00 EmrCreateJobFlowOperator 2023-05-19T17:00:44.855347+00:00 2023-05-19T17:00:45.854007+00:00 0:00:00.998660 382202 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-19T17:00:42.553839+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-19T16:00:00+00:00 PythonOperator 2023-05-19T17:00:22.841240+00:00 2023-05-19T17:00:23.955896+00:00 0:00:01.114656 382201 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-19T17:00:20.547281+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-19T15:00:00+00:00 TriggerDagRunOperator 2023-05-19T16:16:31.259142+00:00 2023-05-19T16:16:31.736284+00:00 0:00:00.477142 382186 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-19T16:16:28.302258+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-19T15:00:00+00:00 TriggerDagRunOperator 2023-05-19T16:16:31.272922+00:00 2023-05-19T16:16:31.755824+00:00 0:00:00.482902 382185 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-19T16:16:28.302291+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-19T15:00:00+00:00 EmrJobFlowSensor 2023-05-19T16:00:52.803357+00:00 2023-05-19T16:10:54.738968+00:00 0:10:01.935611 382181 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-19T16:00:50.491278+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-19T15:00:00+00:00 EmrCreateJobFlowOperator 2023-05-19T16:00:32.754014+00:00 2023-05-19T16:00:33.680899+00:00 0:00:00.926885 382179 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-19T16:00:30.470711+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-19T15:00:00+00:00 PythonOperator 2023-05-19T16:00:10.828142+00:00 2023-05-19T16:00:11.944346+00:00 0:00:01.116204 382177 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-19T16:00:08.437571+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-19T14:00:00+00:00 TriggerDagRunOperator 2023-05-19T15:23:07.734580+00:00 2023-05-19T15:23:08.160253+00:00 0:00:00.425673 382167 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-19T15:23:05.083452+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-19T14:00:00+00:00 TriggerDagRunOperator 2023-05-19T15:23:07.629125+00:00 2023-05-19T15:23:08.088831+00:00 0:00:00.459706 382166 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-19T15:23:05.083483+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-19T14:00:00+00:00 EmrJobFlowSensor 2023-05-19T15:09:57.765800+00:00 2023-05-19T15:20:59.861878+00:00 0:11:02.096078 382163 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-19T15:09:55.309463+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-19T14:00:00+00:00 EmrCreateJobFlowOperator 2023-05-19T15:09:35.930799+00:00 2023-05-19T15:09:36.967773+00:00 0:00:01.036974 382160 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-19T15:09:33.240028+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-19T14:00:00+00:00 PythonOperator 2023-05-19T15:09:15.658462+00:00 2023-05-19T15:09:16.912865+00:00 0:00:01.254403 382157 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-19T15:09:13.221672+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-19T13:00:00+00:00 TriggerDagRunOperator 2023-05-19T14:17:12.295214+00:00 2023-05-19T14:17:12.765522+00:00 0:00:00.470308 382142 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-19T14:17:09.321546+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-19T13:00:00+00:00 TriggerDagRunOperator 2023-05-19T14:17:12.244126+00:00 2023-05-19T14:17:12.714044+00:00 0:00:00.469918 382141 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-19T14:17:09.321510+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-19T13:00:00+00:00 EmrJobFlowSensor 2023-05-19T14:00:46.617335+00:00 2023-05-19T14:10:48.497105+00:00 0:10:01.879770 382137 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-19T14:00:44.109031+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-19T13:00:00+00:00 EmrCreateJobFlowOperator 2023-05-19T14:00:26.447976+00:00 2023-05-19T14:00:27.290905+00:00 0:00:00.842929 382135 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-19T14:00:24.105504+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-19T13:00:00+00:00 PythonOperator 2023-05-19T14:00:04.451390+00:00 2023-05-19T14:00:05.556591+00:00 0:00:01.105201 382133 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-19T14:00:02.032309+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-19T12:00:00+00:00 TriggerDagRunOperator 2023-05-19T13:34:20.846833+00:00 2023-05-19T13:34:21.293396+00:00 0:00:00.446563 382122 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-19T13:34:17.874810+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-19T12:00:00+00:00 TriggerDagRunOperator 2023-05-19T13:34:20.710909+00:00 2023-05-19T13:34:21.146046+00:00 0:00:00.435137 382121 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-19T13:34:17.874780+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-19T12:00:00+00:00 EmrJobFlowSensor 2023-05-19T13:01:01.783589+00:00 2023-05-19T13:11:03.638979+00:00 0:10:01.855390 382114 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-19T13:00:59.589380+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-19T12:00:00+00:00 EmrCreateJobFlowOperator 2023-05-19T13:00:39.753112+00:00 2023-05-19T13:00:40.602777+00:00 0:00:00.849665 382112 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-19T13:00:37.533834+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-19T12:00:00+00:00 PythonOperator 2023-05-19T13:00:17.743605+00:00 2023-05-19T13:00:18.764373+00:00 0:00:01.020768 382110 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-19T13:00:15.513440+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-19T11:00:00+00:00 TriggerDagRunOperator 2023-05-19T12:18:47.059747+00:00 2023-05-19T12:18:47.526768+00:00 0:00:00.467021 382098 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-19T12:18:43.985587+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-19T11:00:00+00:00 TriggerDagRunOperator 2023-05-19T12:18:46.996046+00:00 2023-05-19T12:18:47.460293+00:00 0:00:00.464247 382097 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-19T12:18:43.985632+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-19T11:00:00+00:00 EmrJobFlowSensor 2023-05-19T12:07:25.506830+00:00 2023-05-19T12:18:27.646629+00:00 0:11:02.139799 382092 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-19T12:07:23.210570+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-19T11:00:00+00:00 EmrCreateJobFlowOperator 2023-05-19T12:07:03.410044+00:00 2023-05-19T12:07:04.687405+00:00 0:00:01.277361 382089 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-19T12:07:01.175067+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-19T11:00:00+00:00 PythonOperator 2023-05-19T12:06:43.878895+00:00 2023-05-19T12:06:44.846412+00:00 0:00:00.967517 382086 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-19T12:06:41.200140+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-19T10:00:00+00:00 TriggerDagRunOperator 2023-05-19T11:13:37.223936+00:00 2023-05-19T11:13:37.676235+00:00 0:00:00.452299 382075 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-19T11:13:34.943671+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-19T10:00:00+00:00 TriggerDagRunOperator 2023-05-19T11:13:37.215966+00:00 2023-05-19T11:13:37.678907+00:00 0:00:00.462941 382074 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-19T11:13:34.943638+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-19T10:00:00+00:00 EmrJobFlowSensor 2023-05-19T11:01:04.629772+00:00 2023-05-19T11:11:06.565261+00:00 0:10:01.935489 382068 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-19T11:01:02.196129+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-19T10:00:00+00:00 EmrCreateJobFlowOperator 2023-05-19T11:00:44.528937+00:00 2023-05-19T11:00:45.677389+00:00 0:00:01.148452 382066 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-19T11:00:42.191513+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-19T10:00:00+00:00 PythonOperator 2023-05-19T11:00:22.619959+00:00 2023-05-19T11:00:23.725355+00:00 0:00:01.105396 382064 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-19T11:00:20.180461+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-19T09:00:00+00:00 TriggerDagRunOperator 2023-05-19T10:12:26.447406+00:00 2023-05-19T10:12:26.894583+00:00 0:00:00.447177 382053 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-19T10:12:24.119355+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-19T09:00:00+00:00 TriggerDagRunOperator 2023-05-19T10:12:26.338046+00:00 2023-05-19T10:12:26.808988+00:00 0:00:00.470942 382052 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-19T10:12:24.119323+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-19T09:00:00+00:00 EmrJobFlowSensor 2023-05-19T10:01:04.162105+00:00 2023-05-19T10:12:06.252470+00:00 0:11:02.090365 382045 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-19T10:01:01.715080+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-19T09:00:00+00:00 EmrCreateJobFlowOperator 2023-05-19T10:00:44.042403+00:00 2023-05-19T10:00:45.379416+00:00 0:00:01.337013 382043 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-19T10:00:41.687098+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-19T09:00:00+00:00 PythonOperator 2023-05-19T10:00:23.195411+00:00 2023-05-19T10:00:25.285181+00:00 0:00:02.089770 382041 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-19T10:00:19.703618+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-19T08:00:00+00:00 TriggerDagRunOperator 2023-05-19T09:12:03.946848+00:00 2023-05-19T09:12:04.395279+00:00 0:00:00.448431 382029 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-19T09:12:01.656569+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-19T08:00:00+00:00 TriggerDagRunOperator 2023-05-19T09:12:03.886242+00:00 2023-05-19T09:12:04.352927+00:00 0:00:00.466685 382028 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-19T09:12:01.656539+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-19T08:00:00+00:00 EmrJobFlowSensor 2023-05-19T09:00:53.357657+00:00 2023-05-19T09:11:55.445103+00:00 0:11:02.087446 382022 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-19T09:00:50.911618+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-19T08:00:00+00:00 EmrCreateJobFlowOperator 2023-05-19T09:00:31.390205+00:00 2023-05-19T09:00:32.350409+00:00 0:00:00.960204 382020 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-19T09:00:28.901654+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-19T08:00:00+00:00 PythonOperator 2023-05-19T09:00:11.531152+00:00 2023-05-19T09:00:12.812289+00:00 0:00:01.281137 382018 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-19T09:00:08.823021+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-19T07:00:00+00:00 TriggerDagRunOperator 2023-05-19T08:14:28.033534+00:00 2023-05-19T08:14:28.476892+00:00 0:00:00.443358 382003 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-19T08:14:25.568643+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-19T07:00:00+00:00 TriggerDagRunOperator 2023-05-19T08:14:27.918627+00:00 2023-05-19T08:14:28.390565+00:00 0:00:00.471938 382002 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-19T08:14:25.568673+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-19T07:00:00+00:00 EmrJobFlowSensor 2023-05-19T08:01:19.771658+00:00 2023-05-19T08:11:21.689863+00:00 0:10:01.918205 381995 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-19T08:01:17.311273+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-19T07:00:00+00:00 EmrCreateJobFlowOperator 2023-05-19T08:00:57.476012+00:00 2023-05-19T08:00:58.449903+00:00 0:00:00.973891 381993 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-19T08:00:55.253155+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-19T07:00:00+00:00 PythonOperator 2023-05-19T08:00:37.772590+00:00 2023-05-19T08:00:38.927918+00:00 0:00:01.155328 381991 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-19T08:00:35.298314+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-19T06:00:00+00:00 TriggerDagRunOperator 2023-05-19T07:18:43.389756+00:00 2023-05-19T07:18:43.957490+00:00 0:00:00.567734 381980 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-19T07:18:40.121299+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-19T06:00:00+00:00 TriggerDagRunOperator 2023-05-19T07:18:43.131102+00:00 2023-05-19T07:18:43.594094+00:00 0:00:00.462992 381979 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-19T07:18:40.121342+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-19T06:00:00+00:00 EmrJobFlowSensor 2023-05-19T07:00:51.326065+00:00 2023-05-19T07:10:53.268909+00:00 0:10:01.942844 381972 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-19T07:00:48.893915+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-19T06:00:00+00:00 EmrCreateJobFlowOperator 2023-05-19T07:00:31.077529+00:00 2023-05-19T07:00:32.038450+00:00 0:00:00.960921 381970 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-19T07:00:28.804880+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-19T06:00:00+00:00 PythonOperator 2023-05-19T07:00:09.177909+00:00 2023-05-19T07:00:10.199759+00:00 0:00:01.021850 381968 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-19T07:00:06.754205+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-19T05:00:00+00:00 TriggerDagRunOperator 2023-05-19T06:11:48.942016+00:00 2023-05-19T06:11:49.411505+00:00 0:00:00.469489 381955 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-19T06:11:46.414574+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-19T05:00:00+00:00 TriggerDagRunOperator 2023-05-19T06:11:48.922363+00:00 2023-05-19T06:11:49.366415+00:00 0:00:00.444052 381954 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-19T06:11:46.414602+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-19T05:00:00+00:00 EmrJobFlowSensor 2023-05-19T06:01:33.685297+00:00 2023-05-19T06:11:35.615163+00:00 0:10:01.929866 381947 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-19T06:01:31.351679+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-19T05:00:00+00:00 EmrCreateJobFlowOperator 2023-05-19T06:01:11.675399+00:00 2023-05-19T06:01:12.640076+00:00 0:00:00.964677 381945 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-19T06:01:09.385775+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-19T05:00:00+00:00 PythonOperator 2023-05-19T06:00:50.255284+00:00 2023-05-19T06:00:51.255588+00:00 0:00:01.000304 381943 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-19T06:00:47.312359+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-19T04:00:00+00:00 TriggerDagRunOperator 2023-05-19T05:14:50.951928+00:00 2023-05-19T05:14:51.441729+00:00 0:00:00.489801 381931 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-19T05:14:48.419472+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-19T04:00:00+00:00 TriggerDagRunOperator 2023-05-19T05:14:50.832098+00:00 2023-05-19T05:14:51.294766+00:00 0:00:00.462668 381930 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-19T05:14:48.419500+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-19T04:00:00+00:00 EmrJobFlowSensor 2023-05-19T05:04:26.452217+00:00 2023-05-19T05:14:28.430341+00:00 0:10:01.978124 381923 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-19T05:04:24.240391+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-19T04:00:00+00:00 EmrCreateJobFlowOperator 2023-05-19T05:04:06.433250+00:00 2023-05-19T05:04:07.381205+00:00 0:00:00.947955 381921 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-19T05:04:04.225206+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-19T04:00:00+00:00 PythonOperator 2023-05-19T05:03:44.941591+00:00 2023-05-19T05:03:46.117342+00:00 0:00:01.175751 381919 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-19T05:03:42.206350+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-19T03:00:00+00:00 TriggerDagRunOperator 2023-05-19T04:20:49.924158+00:00 2023-05-19T04:20:50.393616+00:00 0:00:00.469458 381909 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-19T04:20:47.316816+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-19T03:00:00+00:00 TriggerDagRunOperator 2023-05-19T04:20:49.910769+00:00 2023-05-19T04:20:50.366870+00:00 0:00:00.456101 381908 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-19T04:20:47.316787+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-19T03:00:00+00:00 EmrJobFlowSensor 2023-05-19T04:10:29.397263+00:00 2023-05-19T04:20:31.346415+00:00 0:10:01.949152 381903 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-19T04:10:27.082104+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-19T03:00:00+00:00 EmrCreateJobFlowOperator 2023-05-19T04:10:07.255264+00:00 2023-05-19T04:10:08.219819+00:00 0:00:00.964555 381900 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-19T04:10:05.013090+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-19T03:00:00+00:00 PythonOperator 2023-05-19T04:09:47.814974+00:00 2023-05-19T04:09:48.917737+00:00 0:00:01.102763 381897 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-19T04:09:44.998086+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-19T02:00:00+00:00 TriggerDagRunOperator 2023-05-19T03:13:41.042384+00:00 2023-05-19T03:13:41.517697+00:00 0:00:00.475313 381885 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-19T03:13:38.360772+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-19T02:00:00+00:00 TriggerDagRunOperator 2023-05-19T03:13:41.025021+00:00 2023-05-19T03:13:41.462545+00:00 0:00:00.437524 381884 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-19T03:13:38.360815+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-19T02:00:00+00:00 EmrJobFlowSensor 2023-05-19T03:03:15.151899+00:00 2023-05-19T03:13:17.113446+00:00 0:10:01.961547 381878 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-19T03:03:12.836333+00:00 2 default_pool