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-21T14:00:00+00:00 EmrCreateJobFlowOperator 2023-05-21T15:19:09.065996+00:00 2023-05-21T15:19:10.202120+00:00 0:00:01.136124 383346 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-21T15:19:06.434841+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-21T14:00:00+00:00 PythonOperator 2023-05-21T15:00:18.008359+00:00 2023-05-21T15:00:19.271484+00:00 0:00:01.263125 383343 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-21T15:00:15.342505+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-21T13:00:00+00:00 TriggerDagRunOperator 2023-05-21T14:17:32.847463+00:00 2023-05-21T14:17:33.310401+00:00 0:00:00.462938 383333 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-21T14:17:30.131575+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-21T13:00:00+00:00 TriggerDagRunOperator 2023-05-21T14:17:32.746718+00:00 2023-05-21T14:17:33.197176+00:00 0:00:00.450458 383332 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-21T14:17:30.131547+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-21T13:00:00+00:00 EmrJobFlowSensor 2023-05-21T14:07:10.785586+00:00 2023-05-21T14:17:12.702718+00:00 0:10:01.917132 383330 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-21T14:07:08.010452+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-21T13:00:00+00:00 EmrCreateJobFlowOperator 2023-05-21T14:06:48.340665+00:00 2023-05-21T14:06:49.360504+00:00 0:00:01.019839 383325 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-21T14:06:45.985381+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-21T13:00:00+00:00 PythonOperator 2023-05-21T14:06:28.279533+00:00 2023-05-21T14:06:29.240905+00:00 0:00:00.961372 383323 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-21T14:06:25.943641+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-21T12:00:00+00:00 TriggerDagRunOperator 2023-05-21T13:11:02.446108+00:00 2023-05-21T13:11:02.937934+00:00 0:00:00.491826 383311 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-21T13:10:59.898335+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-21T12:00:00+00:00 TriggerDagRunOperator 2023-05-21T13:11:02.406470+00:00 2023-05-21T13:11:02.897168+00:00 0:00:00.490698 383310 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-21T13:10:59.898288+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-21T12:00:00+00:00 EmrJobFlowSensor 2023-05-21T13:00:46.551659+00:00 2023-05-21T13:10:48.540641+00:00 0:10:01.988982 383303 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-21T13:00:44.310922+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-21T12:00:00+00:00 EmrCreateJobFlowOperator 2023-05-21T13:00:24.765515+00:00 2023-05-21T13:00:25.759168+00:00 0:00:00.993653 383301 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-21T13:00:22.291377+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-21T12:00:00+00:00 PythonOperator 2023-05-21T13:00:05.285803+00:00 2023-05-21T13:00:07.481392+00:00 0:00:02.195589 383299 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-21T13:00:02.100673+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-21T11:00:00+00:00 TriggerDagRunOperator 2023-05-21T12:11:19.229699+00:00 2023-05-21T12:11:19.715843+00:00 0:00:00.486144 383287 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-21T12:11:16.608377+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-21T11:00:00+00:00 TriggerDagRunOperator 2023-05-21T12:11:19.192435+00:00 2023-05-21T12:11:19.643665+00:00 0:00:00.451230 383286 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-21T12:11:16.608411+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-21T11:00:00+00:00 EmrJobFlowSensor 2023-05-21T12:00:57.161677+00:00 2023-05-21T12:10:59.214277+00:00 0:10:02.052600 383279 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-21T12:00:54.905347+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-21T11:00:00+00:00 EmrCreateJobFlowOperator 2023-05-21T12:00:35.375601+00:00 2023-05-21T12:00:36.322488+00:00 0:00:00.946887 383277 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-21T12:00:32.902168+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-21T11:00:00+00:00 PythonOperator 2023-05-21T12:00:15.223769+00:00 2023-05-21T12:00:16.209763+00:00 0:00:00.985994 383275 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-21T12:00:12.817510+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-21T10:00:00+00:00 TriggerDagRunOperator 2023-05-21T11:19:18.562280+00:00 2023-05-21T11:19:19.141412+00:00 0:00:00.579132 383265 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-21T11:19:15.405576+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-21T10:00:00+00:00 TriggerDagRunOperator 2023-05-21T11:19:17.919537+00:00 2023-05-21T11:19:18.366186+00:00 0:00:00.446649 383264 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-21T11:19:15.405548+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-21T10:00:00+00:00 EmrJobFlowSensor 2023-05-21T11:06:51.598720+00:00 2023-05-21T11:16:53.518345+00:00 0:10:01.919625 383261 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-21T11:06:49.165815+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-21T10:00:00+00:00 EmrCreateJobFlowOperator 2023-05-21T11:06:29.405653+00:00 2023-05-21T11:06:30.345050+00:00 0:00:00.939397 383257 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-21T11:06:27.144588+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-21T10:00:00+00:00 PythonOperator 2023-05-21T11:06:09.431244+00:00 2023-05-21T11:06:10.495292+00:00 0:00:01.064048 383255 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-21T11:06:07.126405+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-21T09:00:00+00:00 TriggerDagRunOperator 2023-05-21T10:26:50.724131+00:00 2023-05-21T10:26:51.241545+00:00 0:00:00.517414 383241 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-21T10:26:47.800838+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-21T09:00:00+00:00 TriggerDagRunOperator 2023-05-21T10:26:50.702929+00:00 2023-05-21T10:26:51.170019+00:00 0:00:00.467090 383240 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-21T10:26:47.800795+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-21T09:00:00+00:00 EmrJobFlowSensor 2023-05-21T10:16:40.022386+00:00 2023-05-21T10:26:41.928374+00:00 0:10:01.905988 383235 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-21T10:16:37.804004+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-21T09:00:00+00:00 EmrCreateJobFlowOperator 2023-05-21T10:16:17.975749+00:00 2023-05-21T10:16:19.074541+00:00 0:00:01.098792 383232 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-21T10:16:15.739038+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-21T09:00:00+00:00 PythonOperator 2023-05-21T10:15:58.513047+00:00 2023-05-21T10:15:59.707013+00:00 0:00:01.193966 383229 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-21T10:15:55.677235+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-21T08:00:00+00:00 TriggerDagRunOperator 2023-05-21T09:11:07.449715+00:00 2023-05-21T09:11:07.919655+00:00 0:00:00.469940 383217 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-21T09:11:04.900169+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-21T08:00:00+00:00 TriggerDagRunOperator 2023-05-21T09:11:07.422041+00:00 2023-05-21T09:11:07.914299+00:00 0:00:00.492258 383216 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-21T09:11:04.900220+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-21T08:00:00+00:00 EmrJobFlowSensor 2023-05-21T09:00:55.668015+00:00 2023-05-21T09:10:57.542183+00:00 0:10:01.874168 383209 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-21T09:00:53.364474+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-21T08:00:00+00:00 EmrCreateJobFlowOperator 2023-05-21T09:00:33.920243+00:00 2023-05-21T09:00:34.893739+00:00 0:00:00.973496 383207 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-21T09:00:31.409890+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-21T08:00:00+00:00 PythonOperator 2023-05-21T09:00:12.130653+00:00 2023-05-21T09:00:13.300533+00:00 0:00:01.169880 383205 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-21T09:00:09.391801+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-21T07:00:00+00:00 TriggerDagRunOperator 2023-05-21T08:17:52.075467+00:00 2023-05-21T08:17:52.579987+00:00 0:00:00.504520 383194 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-21T08:17:49.495992+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-21T07:00:00+00:00 TriggerDagRunOperator 2023-05-21T08:17:52.036403+00:00 2023-05-21T08:17:52.543897+00:00 0:00:00.507494 383193 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-21T08:17:49.496037+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-21T07:00:00+00:00 EmrJobFlowSensor 2023-05-21T08:07:31.377556+00:00 2023-05-21T08:17:33.967422+00:00 0:10:02.589866 383188 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-21T08:07:28.229027+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-21T07:00:00+00:00 EmrCreateJobFlowOperator 2023-05-21T08:07:09.386881+00:00 2023-05-21T08:07:11.524386+00:00 0:00:02.137505 383185 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-21T08:07:06.204248+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-21T07:00:00+00:00 PythonOperator 2023-05-21T08:06:48.717999+00:00 2023-05-21T08:06:50.346913+00:00 0:00:01.628914 383182 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-21T08:06:46.189531+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-21T06:00:00+00:00 TriggerDagRunOperator 2023-05-21T07:20:44.065612+00:00 2023-05-21T07:20:44.570178+00:00 0:00:00.504566 383172 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-21T07:20:41.293936+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-21T06:00:00+00:00 TriggerDagRunOperator 2023-05-21T07:20:44.044142+00:00 2023-05-21T07:20:44.479268+00:00 0:00:00.435126 383171 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-21T07:20:41.293895+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-21T06:00:00+00:00 EmrJobFlowSensor 2023-05-21T07:01:43.071545+00:00 2023-05-21T07:11:45.006781+00:00 0:10:01.935236 383164 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-21T07:01:40.809259+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-21T06:00:00+00:00 EmrCreateJobFlowOperator 2023-05-21T07:01:21.142637+00:00 2023-05-21T07:01:22.147608+00:00 0:00:01.004971 383163 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-21T07:01:18.746772+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-21T06:00:00+00:00 PythonOperator 2023-05-21T07:01:01.619550+00:00 2023-05-21T07:01:02.610025+00:00 0:00:00.990475 383161 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-21T07:00:58.704093+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-21T05:00:00+00:00 TriggerDagRunOperator 2023-05-21T06:20:39.938211+00:00 2023-05-21T06:20:40.401291+00:00 0:00:00.463080 383148 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-21T06:20:37.312079+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-21T05:00:00+00:00 TriggerDagRunOperator 2023-05-21T06:20:39.778146+00:00 2023-05-21T06:20:40.219709+00:00 0:00:00.441563 383147 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-21T06:20:37.312049+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-21T05:00:00+00:00 EmrJobFlowSensor 2023-05-21T06:10:32.905631+00:00 2023-05-21T06:20:34.848189+00:00 0:10:01.942558 383142 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-21T06:10:30.614479+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-21T05:00:00+00:00 EmrCreateJobFlowOperator 2023-05-21T06:10:12.827072+00:00 2023-05-21T06:10:13.851157+00:00 0:00:01.024085 383139 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-21T06:10:10.595944+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-21T05:00:00+00:00 PythonOperator 2023-05-21T06:09:51.265890+00:00 2023-05-21T06:09:52.242614+00:00 0:00:00.976724 383136 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-21T06:09:48.646931+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-21T04:00:00+00:00 TriggerDagRunOperator 2023-05-21T05:11:17.242966+00:00 2023-05-21T05:11:17.709314+00:00 0:00:00.466348 383124 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-21T05:11:14.818670+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-21T04:00:00+00:00 TriggerDagRunOperator 2023-05-21T05:11:17.229841+00:00 2023-05-21T05:11:17.689874+00:00 0:00:00.460033 383123 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-21T05:11:14.818723+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-21T04:00:00+00:00 EmrJobFlowSensor 2023-05-21T05:00:52.614670+00:00 2023-05-21T05:10:55.010907+00:00 0:10:02.396237 383116 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-21T05:00:50.314425+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-21T04:00:00+00:00 EmrCreateJobFlowOperator 2023-05-21T05:00:30.616775+00:00 2023-05-21T05:00:31.969275+00:00 0:00:01.352500 383114 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-21T05:00:28.254891+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-21T04:00:00+00:00 PythonOperator 2023-05-21T05:00:11.412896+00:00 2023-05-21T05:00:13.454778+00:00 0:00:02.041882 383112 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-21T05:00:08.236573+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-21T03:00:00+00:00 TriggerDagRunOperator 2023-05-21T04:11:13.051952+00:00 2023-05-21T04:11:13.493119+00:00 0:00:00.441167 383100 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-21T04:11:10.491689+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-21T03:00:00+00:00 TriggerDagRunOperator 2023-05-21T04:11:12.932034+00:00 2023-05-21T04:11:13.391590+00:00 0:00:00.459556 383099 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-21T04:11:10.491640+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-21T03:00:00+00:00 EmrJobFlowSensor 2023-05-21T04:00:52.034879+00:00 2023-05-21T04:10:54.015918+00:00 0:10:01.981039 383093 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-21T04:00:49.203539+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-21T03:00:00+00:00 EmrCreateJobFlowOperator 2023-05-21T04:00:31.364034+00:00 2023-05-21T04:00:32.335233+00:00 0:00:00.971199 383091 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-21T04:00:29.121217+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-21T03:00:00+00:00 PythonOperator 2023-05-21T04:00:10.337429+00:00 2023-05-21T04:00:11.514356+00:00 0:00:01.176927 383089 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-21T04:00:07.111951+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-21T02:00:00+00:00 TriggerDagRunOperator 2023-05-21T03:30:37.370613+00:00 2023-05-21T03:30:37.847864+00:00 0:00:00.477251 383076 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-21T03:30:34.390697+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-21T02:00:00+00:00 TriggerDagRunOperator 2023-05-21T03:30:37.352902+00:00 2023-05-21T03:30:37.827577+00:00 0:00:00.474675 383075 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-21T03:30:34.390663+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-21T02:00:00+00:00 EmrJobFlowSensor 2023-05-21T03:00:56.342089+00:00 2023-05-21T03:10:58.306787+00:00 0:10:01.964698 383071 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-21T03:00:54.050122+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-21T02:00:00+00:00 EmrCreateJobFlowOperator 2023-05-21T03:00:34.604733+00:00 2023-05-21T03:00:35.569493+00:00 0:00:00.964760 383069 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-21T03:00:32.093652+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-21T02:00:00+00:00 PythonOperator 2023-05-21T03:00:14.396885+00:00 2023-05-21T03:00:15.362866+00:00 0:00:00.965981 383067 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-21T03:00:12.012958+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-21T01:00:00+00:00 TriggerDagRunOperator 2023-05-21T02:16:32.430728+00:00 2023-05-21T02:16:32.964802+00:00 0:00:00.534074 383056 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-21T02:16:29.698052+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-21T01:00:00+00:00 TriggerDagRunOperator 2023-05-21T02:16:32.082191+00:00 2023-05-21T02:16:32.596566+00:00 0:00:00.514375 383055 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-21T02:16:29.698025+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-21T01:00:00+00:00 EmrJobFlowSensor 2023-05-21T02:00:54.949015+00:00 2023-05-21T02:10:56.894854+00:00 0:10:01.945839 383047 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-21T02:00:52.549065+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-21T01:00:00+00:00 EmrCreateJobFlowOperator 2023-05-21T02:00:32.750202+00:00 2023-05-21T02:00:33.646615+00:00 0:00:00.896413 383045 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-21T02:00:30.532007+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-21T01:00:00+00:00 PythonOperator 2023-05-21T02:00:11.191245+00:00 2023-05-21T02:00:12.154761+00:00 0:00:00.963516 383043 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-21T02:00:08.544129+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-21T00:00:00+00:00 TriggerDagRunOperator 2023-05-21T01:11:26.434457+00:00 2023-05-21T01:11:26.917260+00:00 0:00:00.482803 383024 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-21T01:11:23.807774+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-21T00:00:00+00:00 TriggerDagRunOperator 2023-05-21T01:11:26.322330+00:00 2023-05-21T01:11:26.768541+00:00 0:00:00.446211 383023 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-21T01:11:23.807745+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-21T00:00:00+00:00 EmrJobFlowSensor 2023-05-21T01:00:46.607926+00:00 2023-05-21T01:10:48.497040+00:00 0:10:01.889114 383015 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-21T01:00:44.359178+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-21T00:00:00+00:00 EmrCreateJobFlowOperator 2023-05-21T01:00:24.857470+00:00 2023-05-21T01:00:25.741514+00:00 0:00:00.884044 383013 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-21T01:00:22.402002+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-21T00:00:00+00:00 PythonOperator 2023-05-21T01:00:05.208096+00:00 2023-05-21T01:00:06.322417+00:00 0:00:01.114321 383011 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-21T01:00:02.198950+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-20T23:00:00+00:00 TriggerDagRunOperator 2023-05-21T00:11:22.388449+00:00 2023-05-21T00:11:22.866078+00:00 0:00:00.477629 382998 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-21T00:11:19.893422+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-20T23:00:00+00:00 TriggerDagRunOperator 2023-05-21T00:11:22.333170+00:00 2023-05-21T00:11:22.779800+00:00 0:00:00.446630 382997 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-21T00:11:19.893377+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-20T23:00:00+00:00 EmrJobFlowSensor 2023-05-21T00:01:01.358046+00:00 2023-05-21T00:11:03.409969+00:00 0:10:02.051923 382990 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-21T00:00:58.550330+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-20T23:00:00+00:00 EmrCreateJobFlowOperator 2023-05-21T00:00:40.748174+00:00 2023-05-21T00:00:41.699505+00:00 0:00:00.951331 382988 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-21T00:00:38.477417+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-20T23:00:00+00:00 PythonOperator 2023-05-21T00:00:20.410012+00:00 2023-05-21T00:00:21.561909+00:00 0:00:01.151897 382986 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-21T00:00:16.455853+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-20T22:00:00+00:00 TriggerDagRunOperator 2023-05-20T23:11:26.163424+00:00 2023-05-20T23:11:26.645454+00:00 0:00:00.482030 382972 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-20T23:11:23.713623+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-20T22:00:00+00:00 TriggerDagRunOperator 2023-05-20T23:11:26.110199+00:00 2023-05-20T23:11:26.572202+00:00 0:00:00.462003 382971 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-20T23:11:23.713652+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-20T22:00:00+00:00 EmrJobFlowSensor 2023-05-20T23:00:59.179403+00:00 2023-05-20T23:11:01.744380+00:00 0:10:02.564977 382962 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-20T23:00:56.793632+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-20T22:00:00+00:00 EmrCreateJobFlowOperator 2023-05-20T23:00:39.122417+00:00 2023-05-20T23:00:40.187726+00:00 0:00:01.065309 382959 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-20T23:00:36.776728+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-20T22:00:00+00:00 PythonOperator 2023-05-20T23:00:17.175209+00:00 2023-05-20T23:00:18.307598+00:00 0:00:01.132389 382956 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-20T23:00:14.724705+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-20T21:00:00+00:00 TriggerDagRunOperator 2023-05-20T22:10:55.443292+00:00 2023-05-20T22:10:55.950145+00:00 0:00:00.506853 382943 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-20T22:10:52.784248+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-20T21:00:00+00:00 TriggerDagRunOperator 2023-05-20T22:10:55.391192+00:00 2023-05-20T22:10:55.840611+00:00 0:00:00.449419 382942 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-20T22:10:52.784203+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-20T21:00:00+00:00 EmrJobFlowSensor 2023-05-20T22:00:47.686139+00:00 2023-05-20T22:10:49.637688+00:00 0:10:01.951549 382934 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-20T22:00:45.445488+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-20T21:00:00+00:00 EmrCreateJobFlowOperator 2023-05-20T22:00:27.736501+00:00 2023-05-20T22:00:28.610267+00:00 0:00:00.873766 382932 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-20T22:00:25.425291+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-20T21:00:00+00:00 PythonOperator 2023-05-20T22:00:06.286570+00:00 2023-05-20T22:00:07.302609+00:00 0:00:01.016039 382930 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-20T22:00:03.508487+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-20T20:00:00+00:00 TriggerDagRunOperator 2023-05-20T21:11:24.937466+00:00 2023-05-20T21:11:25.390655+00:00 0:00:00.453189 382917 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-20T21:11:21.993465+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-20T20:00:00+00:00 TriggerDagRunOperator 2023-05-20T21:11:24.873371+00:00 2023-05-20T21:11:25.297457+00:00 0:00:00.424086 382916 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-20T21:11:21.993421+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-20T20:00:00+00:00 EmrJobFlowSensor 2023-05-20T21:01:02.573796+00:00 2023-05-20T21:11:04.668470+00:00 0:10:02.094674 382908 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-20T21:01:00.313552+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-20T20:00:00+00:00 EmrCreateJobFlowOperator 2023-05-20T21:00:42.563264+00:00 2023-05-20T21:00:43.543091+00:00 0:00:00.979827 382906 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-20T21:00:40.257440+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-20T20:00:00+00:00 PythonOperator 2023-05-20T21:00:20.621420+00:00 2023-05-20T21:00:21.844165+00:00 0:00:01.222745 382904 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-20T21:00:18.239612+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-20T19:00:00+00:00 TriggerDagRunOperator 2023-05-20T20:11:15.843808+00:00 2023-05-20T20:11:16.325852+00:00 0:00:00.482044 382891 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-20T20:11:13.200238+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-20T19:00:00+00:00 TriggerDagRunOperator 2023-05-20T20:11:15.796451+00:00 2023-05-20T20:11:16.322797+00:00 0:00:00.526346 382890 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-20T20:11:13.200282+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-20T19:00:00+00:00 EmrJobFlowSensor 2023-05-20T20:01:05.525345+00:00 2023-05-20T20:11:07.410060+00:00 0:10:01.884715 382883 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-20T20:01:03.233904+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-20T19:00:00+00:00 EmrCreateJobFlowOperator 2023-05-20T20:00:43.421010+00:00 2023-05-20T20:00:44.420018+00:00 0:00:00.999008 382881 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-20T20:00:41.214479+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-20T19:00:00+00:00 PythonOperator 2023-05-20T20:00:21.470257+00:00 2023-05-20T20:00:22.424488+00:00 0:00:00.954231 382879 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-20T20:00:19.195187+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-20T18:00:00+00:00 TriggerDagRunOperator 2023-05-20T19:11:24.627254+00:00 2023-05-20T19:11:25.049112+00:00 0:00:00.421858 382863 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-20T19:11:22.118297+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-20T18:00:00+00:00 TriggerDagRunOperator 2023-05-20T19:11:24.349710+00:00 2023-05-20T19:11:24.858878+00:00 0:00:00.509168 382862 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-20T19:11:22.118255+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-20T18:00:00+00:00 EmrJobFlowSensor 2023-05-20T19:01:04.412003+00:00 2023-05-20T19:11:06.379819+00:00 0:10:01.967816 382854 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-20T19:01:02.093696+00:00 2 default_pool