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 check_cluster_status 2023-03-14T19:00:00+00:00 EmrJobFlowSensor 2023-03-14T20:00:58.367329+00:00 2023-03-14T20:11:00.086289+00:00 0:10:01.718960 353608 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-14T20:00:56.200884+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-14T19:00:00+00:00 EmrCreateJobFlowOperator 2023-03-14T20:00:36.872052+00:00 2023-03-14T20:00:37.751628+00:00 0:00:00.879576 353606 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-14T20:00:34.198030+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-14T19:00:00+00:00 PythonOperator 2023-03-14T20:00:15.114294+00:00 2023-03-14T20:00:19.086079+00:00 0:00:03.971785 353604 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-14T20:00:12.117027+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-14T18:00:00+00:00 TriggerDagRunOperator 2023-03-14T19:10:59.120949+00:00 2023-03-14T19:10:59.572575+00:00 0:00:00.451626 353593 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-14T19:10:56.570588+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-14T18:00:00+00:00 TriggerDagRunOperator 2023-03-14T19:10:58.810913+00:00 2023-03-14T19:10:59.288722+00:00 0:00:00.477809 353592 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-14T19:10:56.570552+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-14T18:00:00+00:00 EmrJobFlowSensor 2023-03-14T19:00:47.572553+00:00 2023-03-14T19:10:49.507384+00:00 0:10:01.934831 353585 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-14T19:00:45.387373+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-14T18:00:00+00:00 EmrCreateJobFlowOperator 2023-03-14T19:00:27.647578+00:00 2023-03-14T19:00:28.508093+00:00 0:00:00.860515 353583 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-14T19:00:25.370605+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-14T18:00:00+00:00 PythonOperator 2023-03-14T19:00:06.167774+00:00 2023-03-14T19:00:09.360889+00:00 0:00:03.193115 353581 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-14T19:00:03.350642+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-14T17:00:00+00:00 TriggerDagRunOperator 2023-03-14T18:11:28.289873+00:00 2023-03-14T18:11:28.785301+00:00 0:00:00.495428 353570 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-14T18:11:25.852125+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-14T17:00:00+00:00 TriggerDagRunOperator 2023-03-14T18:11:28.124874+00:00 2023-03-14T18:11:28.583525+00:00 0:00:00.458651 353569 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-14T18:11:25.852091+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-14T17:00:00+00:00 EmrJobFlowSensor 2023-03-14T18:01:08.212794+00:00 2023-03-14T18:11:10.127745+00:00 0:10:01.914951 353563 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-14T18:01:05.844211+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-14T17:00:00+00:00 EmrCreateJobFlowOperator 2023-03-14T18:00:46.312951+00:00 2023-03-14T18:00:47.174523+00:00 0:00:00.861572 353561 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-14T18:00:43.954208+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-14T17:00:00+00:00 PythonOperator 2023-03-14T18:00:24.354218+00:00 2023-03-14T18:00:27.385320+00:00 0:00:03.031102 353559 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-14T18:00:21.800532+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-14T16:00:00+00:00 TriggerDagRunOperator 2023-03-14T17:11:16.658165+00:00 2023-03-14T17:11:17.216694+00:00 0:00:00.558529 353547 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-14T17:11:14.281337+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-14T16:00:00+00:00 TriggerDagRunOperator 2023-03-14T17:11:16.546208+00:00 2023-03-14T17:11:17.053063+00:00 0:00:00.506855 353546 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-14T17:11:14.281370+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-14T16:00:00+00:00 EmrJobFlowSensor 2023-03-14T17:00:55.789155+00:00 2023-03-14T17:10:57.719187+00:00 0:10:01.930032 353540 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-14T17:00:53.218694+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-14T16:00:00+00:00 EmrCreateJobFlowOperator 2023-03-14T17:00:36.273537+00:00 2023-03-14T17:00:37.149793+00:00 0:00:00.876256 353538 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-14T17:00:33.210501+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-14T16:00:00+00:00 PythonOperator 2023-03-14T17:00:13.559761+00:00 2023-03-14T17:00:18.103835+00:00 0:00:04.544074 353536 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-14T17:00:11.198008+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-14T15:00:00+00:00 TriggerDagRunOperator 2023-03-14T16:15:13.666168+00:00 2023-03-14T16:15:14.218293+00:00 0:00:00.552125 353527 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-14T16:15:11.175437+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-14T15:00:00+00:00 TriggerDagRunOperator 2023-03-14T16:15:13.642624+00:00 2023-03-14T16:15:14.121094+00:00 0:00:00.478470 353526 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-14T16:15:11.175408+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-14T15:00:00+00:00 EmrJobFlowSensor 2023-03-14T16:05:03.490235+00:00 2023-03-14T16:15:05.739012+00:00 0:10:02.248777 353519 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-14T16:05:00.985249+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-14T15:00:00+00:00 EmrCreateJobFlowOperator 2023-03-14T16:04:43.328923+00:00 2023-03-14T16:04:44.483432+00:00 0:00:01.154509 353518 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-14T16:04:40.969660+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-14T15:00:00+00:00 PythonOperator 2023-03-14T16:04:21.590889+00:00 2023-03-14T16:04:25.161801+00:00 0:00:03.570912 353515 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-14T16:04:18.952993+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-14T14:00:00+00:00 TriggerDagRunOperator 2023-03-14T15:17:22.320405+00:00 2023-03-14T15:17:22.814677+00:00 0:00:00.494272 353505 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-14T15:17:19.846756+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-14T14:00:00+00:00 TriggerDagRunOperator 2023-03-14T15:17:22.210483+00:00 2023-03-14T15:17:22.655967+00:00 0:00:00.445484 353504 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-14T15:17:19.846785+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-14T14:00:00+00:00 EmrJobFlowSensor 2023-03-14T15:06:55.664229+00:00 2023-03-14T15:16:57.526591+00:00 0:10:01.862362 353499 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-14T15:06:53.451029+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-14T14:00:00+00:00 EmrCreateJobFlowOperator 2023-03-14T15:06:37.610380+00:00 2023-03-14T15:06:38.992344+00:00 0:00:01.381964 353497 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-14T15:06:33.424842+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-14T14:00:00+00:00 PythonOperator 2023-03-14T15:06:16.251251+00:00 2023-03-14T15:06:20.580514+00:00 0:00:04.329263 353495 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-14T15:06:11.401615+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-14T13:00:00+00:00 TriggerDagRunOperator 2023-03-14T14:13:32.196098+00:00 2023-03-14T14:13:32.692460+00:00 0:00:00.496362 353483 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-14T14:13:29.680556+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-14T13:00:00+00:00 TriggerDagRunOperator 2023-03-14T14:13:32.180917+00:00 2023-03-14T14:13:32.728131+00:00 0:00:00.547214 353482 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-14T14:13:29.680512+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-14T13:00:00+00:00 EmrJobFlowSensor 2023-03-14T14:03:06.179883+00:00 2023-03-14T14:13:08.049193+00:00 0:10:01.869310 353475 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-14T14:03:03.833842+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-14T13:00:00+00:00 EmrCreateJobFlowOperator 2023-03-14T14:02:46.457776+00:00 2023-03-14T14:02:47.292476+00:00 0:00:00.834700 353473 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-14T14:02:43.993379+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-14T13:00:00+00:00 PythonOperator 2023-03-14T14:02:24.151566+00:00 2023-03-14T14:02:28.184041+00:00 0:00:04.032475 353471 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-14T14:02:21.781421+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-14T12:00:00+00:00 TriggerDagRunOperator 2023-03-14T13:15:07.971906+00:00 2023-03-14T13:15:08.437148+00:00 0:00:00.465242 353464 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-14T13:15:05.169112+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-14T12:00:00+00:00 TriggerDagRunOperator 2023-03-14T13:15:07.854665+00:00 2023-03-14T13:15:08.327449+00:00 0:00:00.472784 353463 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-14T13:15:05.169084+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-14T12:00:00+00:00 EmrJobFlowSensor 2023-03-14T13:01:38.864983+00:00 2023-03-14T13:11:40.786025+00:00 0:10:01.921042 353456 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-14T13:01:36.576297+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-14T12:00:00+00:00 EmrCreateJobFlowOperator 2023-03-14T13:01:19.471774+00:00 2023-03-14T13:01:20.382689+00:00 0:00:00.910915 353454 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-14T13:01:16.563589+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-14T12:00:00+00:00 PythonOperator 2023-03-14T13:00:23.739885+00:00 2023-03-14T13:00:27.728136+00:00 0:00:03.988251 353452 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-14T13:00:21.570171+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-14T11:00:00+00:00 TriggerDagRunOperator 2023-03-14T12:16:25.499844+00:00 2023-03-14T12:16:26.018666+00:00 0:00:00.518822 353443 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-14T12:16:22.690782+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-14T11:00:00+00:00 TriggerDagRunOperator 2023-03-14T12:16:25.301918+00:00 2023-03-14T12:16:25.781646+00:00 0:00:00.479728 353442 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-14T12:16:22.690754+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-14T11:00:00+00:00 EmrJobFlowSensor 2023-03-14T12:06:06.372135+00:00 2023-03-14T12:16:08.255694+00:00 0:10:01.883559 353437 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-14T12:06:04.078893+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-14T11:00:00+00:00 EmrCreateJobFlowOperator 2023-03-14T12:05:44.606197+00:00 2023-03-14T12:05:45.658454+00:00 0:00:01.052257 353434 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-14T12:05:42.054338+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-14T11:00:00+00:00 PythonOperator 2023-03-14T12:05:24.819388+00:00 2023-03-14T12:05:31.507071+00:00 0:00:06.687683 353431 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-14T12:05:21.988506+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-14T10:00:00+00:00 TriggerDagRunOperator 2023-03-14T11:16:31.660240+00:00 2023-03-14T11:16:32.156345+00:00 0:00:00.496105 353422 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-14T11:16:28.660175+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-14T10:00:00+00:00 TriggerDagRunOperator 2023-03-14T11:16:31.432169+00:00 2023-03-14T11:16:31.894857+00:00 0:00:00.462688 353421 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-14T11:16:28.660147+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-14T10:00:00+00:00 EmrJobFlowSensor 2023-03-14T11:00:47.567945+00:00 2023-03-14T11:10:49.455864+00:00 0:10:01.887919 353413 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-14T11:00:45.122409+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-14T10:00:00+00:00 EmrCreateJobFlowOperator 2023-03-14T11:00:25.423629+00:00 2023-03-14T11:00:26.256123+00:00 0:00:00.832494 353411 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-14T11:00:23.046069+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-14T10:00:00+00:00 PythonOperator 2023-03-14T11:00:05.525984+00:00 2023-03-14T11:00:08.707454+00:00 0:00:03.181470 353409 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-14T11:00:03.028643+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-14T09:00:00+00:00 TriggerDagRunOperator 2023-03-14T10:11:31.265673+00:00 2023-03-14T10:11:31.800384+00:00 0:00:00.534711 353401 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-14T10:11:28.651049+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-14T09:00:00+00:00 TriggerDagRunOperator 2023-03-14T10:11:31.172891+00:00 2023-03-14T10:11:31.663600+00:00 0:00:00.490709 353400 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-14T10:11:28.651079+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-14T09:00:00+00:00 EmrJobFlowSensor 2023-03-14T10:01:21.868465+00:00 2023-03-14T10:11:23.821770+00:00 0:10:01.953305 353394 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-14T10:01:18.838870+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-14T09:00:00+00:00 EmrCreateJobFlowOperator 2023-03-14T10:01:01.838294+00:00 2023-03-14T10:01:03.177653+00:00 0:00:01.339359 353392 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-14T10:00:56.810661+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-14T09:00:00+00:00 PythonOperator 2023-03-14T10:00:37.133162+00:00 2023-03-14T10:00:40.404201+00:00 0:00:03.271039 353390 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-14T10:00:34.786836+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-14T08:00:00+00:00 TriggerDagRunOperator 2023-03-14T09:21:32.356113+00:00 2023-03-14T09:21:32.848420+00:00 0:00:00.492307 353382 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-14T09:21:29.566258+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-14T08:00:00+00:00 TriggerDagRunOperator 2023-03-14T09:21:32.205419+00:00 2023-03-14T09:21:32.722370+00:00 0:00:00.516951 353381 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-14T09:21:29.566287+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-14T08:00:00+00:00 EmrJobFlowSensor 2023-03-14T09:08:45.384836+00:00 2023-03-14T09:18:47.025199+00:00 0:10:01.640363 353378 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-14T09:08:42.645994+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-14T08:00:00+00:00 EmrCreateJobFlowOperator 2023-03-14T09:08:22.865904+00:00 2023-03-14T09:08:23.792733+00:00 0:00:00.926829 353375 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-14T09:08:20.626107+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-14T08:00:00+00:00 PythonOperator 2023-03-14T09:08:03.042729+00:00 2023-03-14T09:08:06.202465+00:00 0:00:03.159736 353372 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-14T09:08:00.603756+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-14T07:00:00+00:00 TriggerDagRunOperator 2023-03-14T08:11:15.608536+00:00 2023-03-14T08:11:16.141153+00:00 0:00:00.532617 353361 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-14T08:11:13.061562+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-14T07:00:00+00:00 TriggerDagRunOperator 2023-03-14T08:11:15.452563+00:00 2023-03-14T08:11:16.007577+00:00 0:00:00.555014 353360 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-14T08:11:13.061590+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-14T07:00:00+00:00 EmrJobFlowSensor 2023-03-14T08:01:08.727645+00:00 2023-03-14T08:11:10.536752+00:00 0:10:01.809107 353354 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-14T08:01:06.430104+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-14T07:00:00+00:00 EmrCreateJobFlowOperator 2023-03-14T08:00:46.604938+00:00 2023-03-14T08:00:47.399333+00:00 0:00:00.794395 353352 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-14T08:00:44.408329+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-14T07:00:00+00:00 PythonOperator 2023-03-14T08:00:24.531050+00:00 2023-03-14T08:00:27.612130+00:00 0:00:03.081080 353350 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-14T08:00:22.385255+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-14T06:00:00+00:00 TriggerDagRunOperator 2023-03-14T07:11:29.987586+00:00 2023-03-14T07:11:30.545810+00:00 0:00:00.558224 353340 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-14T07:11:27.563899+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-14T06:00:00+00:00 TriggerDagRunOperator 2023-03-14T07:11:29.758847+00:00 2023-03-14T07:11:30.317477+00:00 0:00:00.558630 353339 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-14T07:11:27.563871+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-14T06:00:00+00:00 EmrJobFlowSensor 2023-03-14T07:01:05.215578+00:00 2023-03-14T07:11:07.024116+00:00 0:10:01.808538 353333 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-14T07:01:02.790129+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-14T06:00:00+00:00 EmrCreateJobFlowOperator 2023-03-14T07:00:43.215439+00:00 2023-03-14T07:00:44.064314+00:00 0:00:00.848875 353331 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-14T07:00:40.713574+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-14T06:00:00+00:00 PythonOperator 2023-03-14T07:00:21.153367+00:00 2023-03-14T07:00:25.186087+00:00 0:00:04.032720 353329 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-14T07:00:18.714221+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-14T05:00:00+00:00 TriggerDagRunOperator 2023-03-14T06:16:02.998095+00:00 2023-03-14T06:16:03.874672+00:00 0:00:00.876577 353317 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-14T06:15:58.307121+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-14T05:00:00+00:00 TriggerDagRunOperator 2023-03-14T06:16:01.011082+00:00 2023-03-14T06:16:01.544681+00:00 0:00:00.533599 353316 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-14T06:15:58.307072+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-14T05:00:00+00:00 EmrJobFlowSensor 2023-03-14T06:00:49.237503+00:00 2023-03-14T06:10:50.942793+00:00 0:10:01.705290 353311 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-14T06:00:47.028079+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-14T05:00:00+00:00 EmrCreateJobFlowOperator 2023-03-14T06:00:27.279959+00:00 2023-03-14T06:00:28.155687+00:00 0:00:00.875728 353309 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-14T06:00:25.010327+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-14T05:00:00+00:00 PythonOperator 2023-03-14T06:00:05.612466+00:00 2023-03-14T06:00:08.899535+00:00 0:00:03.287069 353307 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-14T06:00:02.987297+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-14T04:00:00+00:00 TriggerDagRunOperator 2023-03-14T05:11:17.712011+00:00 2023-03-14T05:11:18.235406+00:00 0:00:00.523395 353298 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-14T05:11:14.787911+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-14T04:00:00+00:00 TriggerDagRunOperator 2023-03-14T05:11:17.726998+00:00 2023-03-14T05:11:18.291206+00:00 0:00:00.564208 353297 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-14T05:11:14.787945+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-14T04:00:00+00:00 EmrJobFlowSensor 2023-03-14T05:00:51.838755+00:00 2023-03-14T05:10:53.655456+00:00 0:10:01.816701 353290 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-14T05:00:49.512352+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-14T04:00:00+00:00 EmrCreateJobFlowOperator 2023-03-14T05:00:31.719159+00:00 2023-03-14T05:00:32.646066+00:00 0:00:00.926907 353289 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-14T05:00:29.482400+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-14T04:00:00+00:00 PythonOperator 2023-03-14T05:00:10.088844+00:00 2023-03-14T05:00:14.053705+00:00 0:00:03.964861 353286 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-14T05:00:07.454226+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-14T03:00:00+00:00 TriggerDagRunOperator 2023-03-14T04:14:52.195144+00:00 2023-03-14T04:14:52.853159+00:00 0:00:00.658015 353277 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-14T04:14:49.336290+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-14T03:00:00+00:00 TriggerDagRunOperator 2023-03-14T04:14:52.080021+00:00 2023-03-14T04:14:52.615910+00:00 0:00:00.535889 353276 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-14T04:14:49.336261+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-14T03:00:00+00:00 EmrJobFlowSensor 2023-03-14T04:04:38.735939+00:00 2023-03-14T04:14:41.241545+00:00 0:10:02.505606 353269 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-14T04:04:36.226728+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-14T03:00:00+00:00 EmrCreateJobFlowOperator 2023-03-14T04:04:16.471114+00:00 2023-03-14T04:04:17.312039+00:00 0:00:00.840925 353267 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-14T04:04:14.213099+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-14T03:00:00+00:00 PythonOperator 2023-03-14T04:03:56.721442+00:00 2023-03-14T04:03:59.811459+00:00 0:00:03.090017 353265 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-14T04:03:54.189280+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-14T02:00:00+00:00 TriggerDagRunOperator 2023-03-14T03:22:48.476592+00:00 2023-03-14T03:22:48.958493+00:00 0:00:00.481901 353256 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-14T03:22:45.704158+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-14T02:00:00+00:00 TriggerDagRunOperator 2023-03-14T03:22:48.377946+00:00 2023-03-14T03:22:48.835574+00:00 0:00:00.457628 353255 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-14T03:22:45.704120+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-14T02:00:00+00:00 EmrJobFlowSensor 2023-03-14T03:12:31.612226+00:00 2023-03-14T03:22:33.514188+00:00 0:10:01.901962 353250 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-14T03:12:29.305398+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-14T02:00:00+00:00 EmrCreateJobFlowOperator 2023-03-14T03:12:11.637265+00:00 2023-03-14T03:12:12.479283+00:00 0:00:00.842018 353247 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-14T03:12:09.286271+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-14T02:00:00+00:00 PythonOperator 2023-03-14T03:11:49.991682+00:00 2023-03-14T03:11:53.257506+00:00 0:00:03.265824 353244 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-14T03:11:47.267178+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-14T01:00:00+00:00 TriggerDagRunOperator 2023-03-14T02:11:16.514649+00:00 2023-03-14T02:11:17.000550+00:00 0:00:00.485901 353234 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-14T02:11:14.195864+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-14T01:00:00+00:00 TriggerDagRunOperator 2023-03-14T02:11:16.506030+00:00 2023-03-14T02:11:17.051019+00:00 0:00:00.544989 353233 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-14T02:11:14.195812+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-14T01:00:00+00:00 EmrJobFlowSensor 2023-03-14T02:00:59.663243+00:00 2023-03-14T02:11:01.665319+00:00 0:10:02.002076 353226 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-14T02:00:57.199024+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-14T01:00:00+00:00 EmrCreateJobFlowOperator 2023-03-14T02:00:39.363412+00:00 2023-03-14T02:00:40.327949+00:00 0:00:00.964537 353225 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-14T02:00:37.113509+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-14T01:00:00+00:00 PythonOperator 2023-03-14T02:00:17.667563+00:00 2023-03-14T02:00:21.705147+00:00 0:00:04.037584 353222 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-14T02:00:15.109979+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-14T00:00:00+00:00 TriggerDagRunOperator 2023-03-14T01:11:13.651267+00:00 2023-03-14T01:11:14.341669+00:00 0:00:00.690402 353205 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-14T01:11:11.108408+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-14T00:00:00+00:00 TriggerDagRunOperator 2023-03-14T01:11:13.542723+00:00 2023-03-14T01:11:14.057241+00:00 0:00:00.514518 353204 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-14T01:11:11.108378+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-14T00:00:00+00:00 EmrJobFlowSensor 2023-03-14T01:00:57.602618+00:00 2023-03-14T01:10:59.822433+00:00 0:10:02.219815 353197 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-14T01:00:54.895855+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-14T00:00:00+00:00 EmrCreateJobFlowOperator 2023-03-14T01:00:37.039564+00:00 2023-03-14T01:00:38.249684+00:00 0:00:01.210120 353195 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-14T01:00:34.741611+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-14T00:00:00+00:00 PythonOperator 2023-03-14T01:00:15.751239+00:00 2023-03-14T01:00:21.132568+00:00 0:00:05.381329 353193 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-14T01:00:12.704367+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-13T23:00:00+00:00 TriggerDagRunOperator 2023-03-14T00:11:21.128499+00:00 2023-03-14T00:11:21.621177+00:00 0:00:00.492678 353181 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-14T00:11:18.597212+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-13T23:00:00+00:00 TriggerDagRunOperator 2023-03-14T00:11:21.018530+00:00 2023-03-14T00:11:21.505499+00:00 0:00:00.486969 353180 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-14T00:11:18.597185+00:00 2 default_pool