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-04T02:00:00+00:00 EmrCreateJobFlowOperator 2023-05-04T03:07:38.605847+00:00 2023-05-04T03:07:39.582412+00:00 0:00:00.976565 372672 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-04T03:07:36.197656+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-04T02:00:00+00:00 PythonOperator 2023-05-04T03:07:16.399921+00:00 2023-05-04T03:07:17.317267+00:00 0:00:00.917346 372668 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-04T03:07:14.174259+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-04T01:00:00+00:00 TriggerDagRunOperator 2023-05-04T02:31:34.362148+00:00 2023-05-04T02:31:34.837298+00:00 0:00:00.475150 372656 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-04T02:31:31.764010+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-04T01:00:00+00:00 TriggerDagRunOperator 2023-05-04T02:31:34.218339+00:00 2023-05-04T02:31:34.606537+00:00 0:00:00.388198 372655 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-04T02:31:31.764039+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-04T01:00:00+00:00 EmrJobFlowSensor 2023-05-04T02:18:32.663232+00:00 2023-05-04T02:28:34.616735+00:00 0:10:01.953503 372651 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-04T02:18:30.439130+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-04T01:00:00+00:00 EmrCreateJobFlowOperator 2023-05-04T02:18:11.179118+00:00 2023-05-04T02:18:11.968496+00:00 0:00:00.789378 372648 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-04T02:18:08.436039+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-04T01:00:00+00:00 PythonOperator 2023-05-04T02:17:50.747593+00:00 2023-05-04T02:17:51.633487+00:00 0:00:00.885894 372645 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-04T02:17:48.417967+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-04T00:00:00+00:00 TriggerDagRunOperator 2023-05-04T01:33:53.846386+00:00 2023-05-04T01:33:54.560265+00:00 0:00:00.713879 372629 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-04T01:33:50.325164+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-04T00:00:00+00:00 TriggerDagRunOperator 2023-05-04T01:33:53.125347+00:00 2023-05-04T01:33:53.623126+00:00 0:00:00.497779 372628 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-04T01:33:50.325197+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-04T00:00:00+00:00 EmrJobFlowSensor 2023-05-04T01:16:02.039972+00:00 2023-05-04T01:26:03.936037+00:00 0:10:01.896065 372625 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-04T01:15:59.865084+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-04T00:00:00+00:00 EmrCreateJobFlowOperator 2023-05-04T01:15:42.024870+00:00 2023-05-04T01:15:42.790521+00:00 0:00:00.765651 372622 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-04T01:15:39.838855+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-04T00:00:00+00:00 PythonOperator 2023-05-04T01:15:20.383892+00:00 2023-05-04T01:15:21.587494+00:00 0:00:01.203602 372619 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-04T01:15:17.819442+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-03T23:00:00+00:00 TriggerDagRunOperator 2023-05-04T00:31:46.310617+00:00 2023-05-04T00:31:46.762697+00:00 0:00:00.452080 372605 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-04T00:31:43.246733+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-03T23:00:00+00:00 TriggerDagRunOperator 2023-05-04T00:31:46.226802+00:00 2023-05-04T00:31:46.580269+00:00 0:00:00.353467 372604 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-04T00:31:43.246787+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-03T23:00:00+00:00 EmrJobFlowSensor 2023-05-04T00:00:49.252908+00:00 2023-05-04T00:10:51.119529+00:00 0:10:01.866621 372600 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-04T00:00:46.952725+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-03T23:00:00+00:00 EmrCreateJobFlowOperator 2023-05-04T00:00:29.485925+00:00 2023-05-04T00:00:30.360585+00:00 0:00:00.874660 372598 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-04T00:00:27.004607+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-03T23:00:00+00:00 PythonOperator 2023-05-04T00:00:08.669425+00:00 2023-05-04T00:00:09.912082+00:00 0:00:01.242657 372596 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-04T00:00:04.989270+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-03T22:00:00+00:00 TriggerDagRunOperator 2023-05-03T23:12:55.169368+00:00 2023-05-03T23:12:55.501657+00:00 0:00:00.332289 372585 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-03T23:12:52.395922+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-03T22:00:00+00:00 TriggerDagRunOperator 2023-05-03T23:12:54.814075+00:00 2023-05-03T23:12:55.311394+00:00 0:00:00.497319 372584 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-03T23:12:52.395972+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-03T22:00:00+00:00 EmrJobFlowSensor 2023-05-03T23:12:34.895751+00:00 2023-05-03T23:12:35.470000+00:00 0:00:00.574249 372582 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-03T23:12:32.509301+00:00 3 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-03T22:00:00+00:00 EmrCreateJobFlowOperator 2023-05-03T23:00:44.242150+00:00 2023-05-03T23:00:45.171363+00:00 0:00:00.929213 372572 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-03T23:00:41.414656+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-03T22:00:00+00:00 PythonOperator 2023-05-03T23:00:23.576048+00:00 2023-05-03T23:00:24.526762+00:00 0:00:00.950714 372569 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-03T23:00:21.361096+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-03T21:00:00+00:00 TriggerDagRunOperator 2023-05-03T22:11:22.221664+00:00 2023-05-03T22:11:22.681328+00:00 0:00:00.459664 372554 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-03T22:11:19.797866+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-03T21:00:00+00:00 TriggerDagRunOperator 2023-05-03T22:11:22.170748+00:00 2023-05-03T22:11:22.537850+00:00 0:00:00.367102 372553 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-03T22:11:19.797836+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-03T21:00:00+00:00 EmrJobFlowSensor 2023-05-03T22:01:06.665033+00:00 2023-05-03T22:11:08.596653+00:00 0:10:01.931620 372546 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-03T22:01:04.413282+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-03T21:00:00+00:00 EmrCreateJobFlowOperator 2023-05-03T22:00:46.578693+00:00 2023-05-03T22:00:47.412336+00:00 0:00:00.833643 372544 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-03T22:00:44.342247+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-03T21:00:00+00:00 PythonOperator 2023-05-03T22:00:24.666069+00:00 2023-05-03T22:00:26.384141+00:00 0:00:01.718072 372542 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-03T22:00:22.321928+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-03T20:00:00+00:00 TriggerDagRunOperator 2023-05-03T21:11:23.068231+00:00 2023-05-03T21:11:23.419575+00:00 0:00:00.351344 372528 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-03T21:11:20.661498+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-03T20:00:00+00:00 TriggerDagRunOperator 2023-05-03T21:11:23.065296+00:00 2023-05-03T21:11:23.536210+00:00 0:00:00.470914 372527 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-03T21:11:20.661459+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-03T20:00:00+00:00 EmrJobFlowSensor 2023-05-03T21:01:04.463193+00:00 2023-05-03T21:11:06.324216+00:00 0:10:01.861023 372520 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-03T21:01:02.231553+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-03T20:00:00+00:00 EmrCreateJobFlowOperator 2023-05-03T21:00:44.340145+00:00 2023-05-03T21:00:45.199389+00:00 0:00:00.859244 372518 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-03T21:00:42.212070+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-03T20:00:00+00:00 PythonOperator 2023-05-03T21:00:22.322725+00:00 2023-05-03T21:00:23.273793+00:00 0:00:00.951068 372516 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-03T21:00:20.192230+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-03T19:00:00+00:00 TriggerDagRunOperator 2023-05-03T20:11:19.442203+00:00 2023-05-03T20:11:19.904260+00:00 0:00:00.462057 372501 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-03T20:11:16.993447+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-03T19:00:00+00:00 TriggerDagRunOperator 2023-05-03T20:11:19.354597+00:00 2023-05-03T20:11:19.695249+00:00 0:00:00.340652 372500 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-03T20:11:16.993418+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-03T19:00:00+00:00 EmrJobFlowSensor 2023-05-03T20:00:52.256957+00:00 2023-05-03T20:10:54.397423+00:00 0:10:02.140466 372492 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-03T20:00:49.775744+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-03T19:00:00+00:00 EmrCreateJobFlowOperator 2023-05-03T20:00:31.950108+00:00 2023-05-03T20:00:32.759375+00:00 0:00:00.809267 372490 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-03T20:00:29.761786+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-03T19:00:00+00:00 PythonOperator 2023-05-03T20:00:10.216283+00:00 2023-05-03T20:00:11.189109+00:00 0:00:00.972826 372488 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-03T20:00:07.734582+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-03T18:00:00+00:00 TriggerDagRunOperator 2023-05-03T19:16:31.233256+00:00 2023-05-03T19:16:31.684996+00:00 0:00:00.451740 372474 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-03T19:16:28.591204+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-03T18:00:00+00:00 TriggerDagRunOperator 2023-05-03T19:16:31.130716+00:00 2023-05-03T19:16:31.455737+00:00 0:00:00.325021 372473 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-03T19:16:28.591262+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-03T18:00:00+00:00 EmrJobFlowSensor 2023-05-03T19:06:12.229740+00:00 2023-05-03T19:16:14.141024+00:00 0:10:01.911284 372469 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-03T19:06:10.109178+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-03T18:00:00+00:00 EmrCreateJobFlowOperator 2023-05-03T19:05:50.227385+00:00 2023-05-03T19:05:51.193166+00:00 0:00:00.965781 372467 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-03T19:05:47.966102+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-03T18:00:00+00:00 PythonOperator 2023-05-03T19:05:30.393517+00:00 2023-05-03T19:05:31.445751+00:00 0:00:01.052234 372465 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-03T19:05:27.948050+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-03T17:00:00+00:00 TriggerDagRunOperator 2023-05-03T18:11:03.237752+00:00 2023-05-03T18:11:03.774452+00:00 0:00:00.536700 372447 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-03T18:11:00.910944+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-03T17:00:00+00:00 TriggerDagRunOperator 2023-05-03T18:11:03.114342+00:00 2023-05-03T18:11:03.582284+00:00 0:00:00.467942 372446 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-03T18:11:00.910977+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-03T17:00:00+00:00 EmrJobFlowSensor 2023-05-03T18:00:51.375268+00:00 2023-05-03T18:10:53.195172+00:00 0:10:01.819904 372440 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-03T18:00:49.043560+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-03T17:00:00+00:00 EmrCreateJobFlowOperator 2023-05-03T18:00:29.402608+00:00 2023-05-03T18:00:30.523894+00:00 0:00:01.121286 372439 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-03T18:00:27.086232+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-03T17:00:00+00:00 PythonOperator 2023-05-03T18:00:07.738797+00:00 2023-05-03T18:00:08.716242+00:00 0:00:00.977445 372437 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-03T18:00:05.088705+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-03T16:00:00+00:00 TriggerDagRunOperator 2023-05-03T17:18:37.432339+00:00 2023-05-03T17:18:37.780926+00:00 0:00:00.348587 372426 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-03T17:18:35.011012+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-03T16:00:00+00:00 TriggerDagRunOperator 2023-05-03T17:18:37.430970+00:00 2023-05-03T17:18:37.872598+00:00 0:00:00.441628 372425 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-03T17:18:35.010981+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-03T16:00:00+00:00 EmrJobFlowSensor 2023-05-03T17:08:17.675794+00:00 2023-05-03T17:18:19.493846+00:00 0:10:01.818052 372418 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-03T17:08:15.525964+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-03T16:00:00+00:00 EmrCreateJobFlowOperator 2023-05-03T17:07:57.946057+00:00 2023-05-03T17:07:58.731225+00:00 0:00:00.785168 372415 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-03T17:07:55.562787+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-03T16:00:00+00:00 PythonOperator 2023-05-03T17:00:20.673503+00:00 2023-05-03T17:00:21.647477+00:00 0:00:00.973974 372413 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-03T17:00:18.410850+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-03T15:00:00+00:00 TriggerDagRunOperator 2023-05-03T16:17:30.742635+00:00 2023-05-03T16:17:31.149026+00:00 0:00:00.406391 372404 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-03T16:17:27.908653+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-03T15:00:00+00:00 TriggerDagRunOperator 2023-05-03T16:17:30.717837+00:00 2023-05-03T16:17:31.209861+00:00 0:00:00.492024 372403 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-03T16:17:27.908687+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-03T15:00:00+00:00 EmrJobFlowSensor 2023-05-03T16:01:05.126438+00:00 2023-05-03T16:11:06.835718+00:00 0:10:01.709280 372396 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-03T16:01:02.680379+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-03T15:00:00+00:00 EmrCreateJobFlowOperator 2023-05-03T16:00:43.113875+00:00 2023-05-03T16:00:44.085141+00:00 0:00:00.971266 372394 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-03T16:00:40.631950+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-03T15:00:00+00:00 PythonOperator 2023-05-03T16:00:22.975812+00:00 2023-05-03T16:00:23.930059+00:00 0:00:00.954247 372392 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-03T16:00:20.590540+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-03T14:00:00+00:00 TriggerDagRunOperator 2023-05-03T15:11:04.458868+00:00 2023-05-03T15:11:04.839997+00:00 0:00:00.381129 372379 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-03T15:11:02.199224+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-03T14:00:00+00:00 TriggerDagRunOperator 2023-05-03T15:11:04.433950+00:00 2023-05-03T15:11:04.918399+00:00 0:00:00.484449 372378 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-03T15:11:02.199253+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-03T14:00:00+00:00 EmrJobFlowSensor 2023-05-03T15:00:48.378623+00:00 2023-05-03T15:10:50.328301+00:00 0:10:01.949678 372371 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-03T15:00:46.125228+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-03T14:00:00+00:00 EmrCreateJobFlowOperator 2023-05-03T15:00:26.377307+00:00 2023-05-03T15:00:27.337096+00:00 0:00:00.959789 372369 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-03T15:00:24.078428+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-03T14:00:00+00:00 PythonOperator 2023-05-03T15:00:06.249019+00:00 2023-05-03T15:00:07.190904+00:00 0:00:00.941885 372367 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-03T15:00:04.031752+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-03T13:00:00+00:00 TriggerDagRunOperator 2023-05-03T14:21:41.060306+00:00 2023-05-03T14:21:41.410720+00:00 0:00:00.350414 372357 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-03T14:21:38.531716+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-03T13:00:00+00:00 TriggerDagRunOperator 2023-05-03T14:21:40.980097+00:00 2023-05-03T14:21:41.436395+00:00 0:00:00.456298 372356 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-03T14:21:38.531744+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-03T13:00:00+00:00 EmrJobFlowSensor 2023-05-03T14:09:04.225852+00:00 2023-05-03T14:19:06.161260+00:00 0:10:01.935408 372352 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-03T14:09:01.790322+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-03T13:00:00+00:00 EmrCreateJobFlowOperator 2023-05-03T14:08:42.591721+00:00 2023-05-03T14:08:43.352981+00:00 0:00:00.761260 372349 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-03T14:08:39.804926+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-03T13:00:00+00:00 PythonOperator 2023-05-03T14:08:21.908250+00:00 2023-05-03T14:08:22.770551+00:00 0:00:00.862301 372346 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-03T14:08:19.661777+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-03T12:00:00+00:00 TriggerDagRunOperator 2023-05-03T13:26:07.844980+00:00 2023-05-03T13:26:08.273701+00:00 0:00:00.428721 372334 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-03T13:26:04.794964+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-03T12:00:00+00:00 TriggerDagRunOperator 2023-05-03T13:26:07.719381+00:00 2023-05-03T13:26:08.064475+00:00 0:00:00.345094 372333 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-03T13:26:04.795007+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-03T12:00:00+00:00 EmrJobFlowSensor 2023-05-03T13:07:26.821706+00:00 2023-05-03T13:17:28.565582+00:00 0:10:01.743876 372328 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-03T13:07:24.641117+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-03T12:00:00+00:00 EmrCreateJobFlowOperator 2023-05-03T13:07:06.742686+00:00 2023-05-03T13:07:07.510196+00:00 0:00:00.767510 372325 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-03T13:07:04.618341+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-03T12:00:00+00:00 PythonOperator 2023-05-03T13:06:45.282661+00:00 2023-05-03T13:06:46.191977+00:00 0:00:00.909316 372322 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-03T13:06:42.600570+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-03T11:00:00+00:00 TriggerDagRunOperator 2023-05-03T12:13:11.260756+00:00 2023-05-03T12:13:11.713971+00:00 0:00:00.453215 372310 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-03T12:13:08.392331+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-03T11:00:00+00:00 TriggerDagRunOperator 2023-05-03T12:13:11.224547+00:00 2023-05-03T12:13:11.558675+00:00 0:00:00.334128 372309 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-03T12:13:08.392370+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-03T11:00:00+00:00 EmrJobFlowSensor 2023-05-03T12:01:06.738947+00:00 2023-05-03T12:11:08.613842+00:00 0:10:01.874895 372302 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-03T12:01:04.531749+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-03T11:00:00+00:00 EmrCreateJobFlowOperator 2023-05-03T12:00:44.687264+00:00 2023-05-03T12:00:45.550048+00:00 0:00:00.862784 372300 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-03T12:00:42.473943+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-03T11:00:00+00:00 PythonOperator 2023-05-03T12:00:24.579082+00:00 2023-05-03T12:00:26.265451+00:00 0:00:01.686369 372298 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-03T12:00:22.435808+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-03T10:00:00+00:00 TriggerDagRunOperator 2023-05-03T11:16:16.369724+00:00 2023-05-03T11:16:16.809933+00:00 0:00:00.440209 372284 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-03T11:16:14.054891+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-03T10:00:00+00:00 TriggerDagRunOperator 2023-05-03T11:16:16.240387+00:00 2023-05-03T11:16:16.605704+00:00 0:00:00.365317 372283 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-03T11:16:14.054921+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-03T10:00:00+00:00 EmrJobFlowSensor 2023-05-03T11:00:52.414400+00:00 2023-05-03T11:10:54.135856+00:00 0:10:01.721456 372278 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-03T11:00:50.206923+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-03T10:00:00+00:00 EmrCreateJobFlowOperator 2023-05-03T11:00:30.472642+00:00 2023-05-03T11:00:31.295361+00:00 0:00:00.822719 372276 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-03T11:00:28.163379+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-03T10:00:00+00:00 PythonOperator 2023-05-03T11:00:10.776813+00:00 2023-05-03T11:00:11.733559+00:00 0:00:00.956746 372274 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-03T11:00:08.145008+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-03T09:00:00+00:00 TriggerDagRunOperator 2023-05-03T10:12:00.394643+00:00 2023-05-03T10:12:00.883573+00:00 0:00:00.488930 372264 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-03T10:11:56.987708+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-03T09:00:00+00:00 TriggerDagRunOperator 2023-05-03T10:11:59.876292+00:00 2023-05-03T10:12:00.472125+00:00 0:00:00.595833 372263 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-03T10:11:56.987662+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-03T09:00:00+00:00 EmrJobFlowSensor 2023-05-03T10:00:50.616552+00:00 2023-05-03T10:11:52.661566+00:00 0:11:02.045014 372255 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-03T10:00:48.189744+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-03T09:00:00+00:00 EmrCreateJobFlowOperator 2023-05-03T10:00:28.186064+00:00 2023-05-03T10:00:28.986066+00:00 0:00:00.800002 372253 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-03T10:00:26.038027+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-03T09:00:00+00:00 PythonOperator 2023-05-03T10:00:08.361501+00:00 2023-05-03T10:00:09.375087+00:00 0:00:01.013586 372251 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-03T10:00:06.016952+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-03T08:00:00+00:00 TriggerDagRunOperator 2023-05-03T09:17:02.717270+00:00 2023-05-03T09:17:03.224644+00:00 0:00:00.507374 372241 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-03T09:17:00.160914+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-03T08:00:00+00:00 TriggerDagRunOperator 2023-05-03T09:17:02.450491+00:00 2023-05-03T09:17:02.819704+00:00 0:00:00.369213 372240 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-03T09:17:00.160885+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-03T08:00:00+00:00 EmrJobFlowSensor 2023-05-03T09:00:48.689954+00:00 2023-05-03T09:10:50.517573+00:00 0:10:01.827619 372231 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-03T09:00:46.462823+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-03T08:00:00+00:00 EmrCreateJobFlowOperator 2023-05-03T09:00:26.969660+00:00 2023-05-03T09:00:27.700078+00:00 0:00:00.730418 372229 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-03T09:00:24.492890+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-03T08:00:00+00:00 PythonOperator 2023-05-03T09:00:06.142953+00:00 2023-05-03T09:00:07.364251+00:00 0:00:01.221298 372227 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-03T09:00:02.403715+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-03T07:00:00+00:00 TriggerDagRunOperator 2023-05-03T08:15:35.391256+00:00 2023-05-03T08:15:35.821659+00:00 0:00:00.430403 372217 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-03T08:15:32.399161+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-03T07:00:00+00:00 TriggerDagRunOperator 2023-05-03T08:15:35.330597+00:00 2023-05-03T08:15:35.673588+00:00 0:00:00.342991 372216 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-03T08:15:32.399127+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-03T07:00:00+00:00 EmrJobFlowSensor 2023-05-03T08:04:44.164085+00:00 2023-05-03T08:14:46.096781+00:00 0:10:01.932696 372210 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-03T08:04:41.883566+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-03T07:00:00+00:00 EmrCreateJobFlowOperator 2023-05-03T08:04:22.051968+00:00 2023-05-03T08:04:22.982383+00:00 0:00:00.930415 372207 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-03T08:04:19.829088+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-03T07:00:00+00:00 PythonOperator 2023-05-03T08:04:02.752941+00:00 2023-05-03T08:04:03.669028+00:00 0:00:00.916087 372206 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-03T08:03:59.828018+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-03T06:00:00+00:00 TriggerDagRunOperator 2023-05-03T07:24:18.245002+00:00 2023-05-03T07:24:18.766956+00:00 0:00:00.521954 372193 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-03T07:24:15.107043+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-03T06:00:00+00:00 TriggerDagRunOperator 2023-05-03T07:24:18.131029+00:00 2023-05-03T07:24:18.470224+00:00 0:00:00.339195 372192 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-03T07:24:15.107002+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-03T06:00:00+00:00 EmrJobFlowSensor 2023-05-03T07:13:52.059710+00:00 2023-05-03T07:23:54.175477+00:00 0:10:02.115767 372187 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-03T07:13:49.826675+00:00 2 default_pool