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-14T02:00:00+00:00 EmrCreateJobFlowOperator 2023-05-14T03:04:20.343954+00:00 2023-05-14T03:04:21.333000+00:00 0:00:00.989046 378779 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-14T03:04:17.966207+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-14T02:00:00+00:00 PythonOperator 2023-05-14T03:03:58.722062+00:00 2023-05-14T03:03:59.899315+00:00 0:00:01.177253 378776 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-14T03:03:55.954354+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-14T01:00:00+00:00 TriggerDagRunOperator 2023-05-14T02:13:27.809275+00:00 2023-05-14T02:13:28.267498+00:00 0:00:00.458223 378764 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-14T02:13:24.604189+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-14T01:00:00+00:00 TriggerDagRunOperator 2023-05-14T02:13:27.055222+00:00 2023-05-14T02:13:27.516806+00:00 0:00:00.461584 378763 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-14T02:13:24.604160+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-14T01:00:00+00:00 EmrJobFlowSensor 2023-05-14T02:00:52.830402+00:00 2023-05-14T02:10:55.087742+00:00 0:10:02.257340 378755 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-14T02:00:50.429093+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-14T01:00:00+00:00 EmrCreateJobFlowOperator 2023-05-14T02:00:30.664237+00:00 2023-05-14T02:00:31.380770+00:00 0:00:00.716533 378753 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-14T02:00:28.306577+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-14T01:00:00+00:00 PythonOperator 2023-05-14T02:00:10.583264+00:00 2023-05-14T02:00:11.589603+00:00 0:00:01.006339 378751 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-14T02:00:08.270497+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-14T00:00:00+00:00 TriggerDagRunOperator 2023-05-14T01:11:22.343338+00:00 2023-05-14T01:11:22.838372+00:00 0:00:00.495034 378732 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-14T01:11:19.389384+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-14T00:00:00+00:00 TriggerDagRunOperator 2023-05-14T01:11:22.118310+00:00 2023-05-14T01:11:22.446662+00:00 0:00:00.328352 378731 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-14T01:11:19.389339+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-14T00:00:00+00:00 EmrJobFlowSensor 2023-05-14T01:01:03.368871+00:00 2023-05-14T01:11:05.405663+00:00 0:10:02.036792 378724 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-14T01:01:00.549786+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-14T00:00:00+00:00 EmrCreateJobFlowOperator 2023-05-14T01:00:40.757396+00:00 2023-05-14T01:00:41.559147+00:00 0:00:00.801751 378722 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-14T01:00:38.540635+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-14T00:00:00+00:00 PythonOperator 2023-05-14T01:00:20.655865+00:00 2023-05-14T01:00:21.628599+00:00 0:00:00.972734 378720 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-14T01:00:18.417054+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-13T23:00:00+00:00 TriggerDagRunOperator 2023-05-14T00:14:14.253305+00:00 2023-05-14T00:14:14.730825+00:00 0:00:00.477520 378706 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-14T00:14:11.181312+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-13T23:00:00+00:00 TriggerDagRunOperator 2023-05-14T00:14:14.138887+00:00 2023-05-14T00:14:14.467123+00:00 0:00:00.328236 378705 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-14T00:14:11.181262+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-13T23:00:00+00:00 EmrJobFlowSensor 2023-05-14T00:04:05.824232+00:00 2023-05-14T00:14:07.592465+00:00 0:10:01.768233 378699 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-14T00:04:03.582183+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-13T23:00:00+00:00 EmrCreateJobFlowOperator 2023-05-14T00:03:43.674332+00:00 2023-05-14T00:03:44.540275+00:00 0:00:00.865943 378697 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-14T00:03:41.330151+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-13T23:00:00+00:00 PythonOperator 2023-05-14T00:03:23.343009+00:00 2023-05-14T00:03:24.373278+00:00 0:00:01.030269 378695 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-14T00:03:21.238761+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-13T22:00:00+00:00 TriggerDagRunOperator 2023-05-13T23:12:02.169978+00:00 2023-05-13T23:12:02.613928+00:00 0:00:00.443950 378679 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-13T23:11:59.860631+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-13T22:00:00+00:00 TriggerDagRunOperator 2023-05-13T23:12:02.088393+00:00 2023-05-13T23:12:02.428730+00:00 0:00:00.340337 378678 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-13T23:11:59.860594+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-13T22:00:00+00:00 EmrJobFlowSensor 2023-05-13T23:00:46.460434+00:00 2023-05-13T23:11:48.575217+00:00 0:11:02.114783 378670 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-13T23:00:43.753581+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-13T22:00:00+00:00 EmrCreateJobFlowOperator 2023-05-13T23:00:26.053308+00:00 2023-05-13T23:00:26.950633+00:00 0:00:00.897325 378667 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-13T23:00:23.735232+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-13T22:00:00+00:00 PythonOperator 2023-05-13T23:00:04.267249+00:00 2023-05-13T23:00:05.337846+00:00 0:00:01.070597 378664 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-13T23:00:01.720182+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-13T21:00:00+00:00 TriggerDagRunOperator 2023-05-13T22:11:11.164276+00:00 2023-05-13T22:11:11.495989+00:00 0:00:00.331713 378650 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-13T22:11:08.681497+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-13T21:00:00+00:00 TriggerDagRunOperator 2023-05-13T22:11:10.950953+00:00 2023-05-13T22:11:11.402746+00:00 0:00:00.451793 378649 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-13T22:11:08.681531+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-13T21:00:00+00:00 EmrJobFlowSensor 2023-05-13T22:01:01.524589+00:00 2023-05-13T22:11:03.439152+00:00 0:10:01.914563 378643 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-13T22:00:59.297929+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-13T21:00:00+00:00 EmrCreateJobFlowOperator 2023-05-13T22:00:39.523155+00:00 2023-05-13T22:00:40.615149+00:00 0:00:01.091994 378641 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-13T22:00:37.214540+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-13T21:00:00+00:00 PythonOperator 2023-05-13T22:00:19.425785+00:00 2023-05-13T22:00:20.441758+00:00 0:00:01.015973 378639 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-13T22:00:17.164500+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-13T20:00:00+00:00 TriggerDagRunOperator 2023-05-13T21:13:23.078491+00:00 2023-05-13T21:13:23.536065+00:00 0:00:00.457574 378628 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-13T21:13:20.760748+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-13T20:00:00+00:00 TriggerDagRunOperator 2023-05-13T21:13:23.023540+00:00 2023-05-13T21:13:23.363842+00:00 0:00:00.340302 378627 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-13T21:13:20.760776+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-13T20:00:00+00:00 EmrJobFlowSensor 2023-05-13T21:13:01.062375+00:00 2023-05-13T21:13:01.642456+00:00 0:00:00.580081 378625 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-13T21:12:58.728331+00:00 3 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-13T20:00:00+00:00 EmrCreateJobFlowOperator 2023-05-13T21:00:34.283927+00:00 2023-05-13T21:00:35.113926+00:00 0:00:00.829999 378616 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-13T21:00:32.161177+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-13T20:00:00+00:00 PythonOperator 2023-05-13T21:00:12.516164+00:00 2023-05-13T21:00:13.532138+00:00 0:00:01.015974 378614 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-13T21:00:10.197508+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-13T19:00:00+00:00 TriggerDagRunOperator 2023-05-13T20:11:45.732455+00:00 2023-05-13T20:11:46.080731+00:00 0:00:00.348276 378602 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-13T20:11:42.945868+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-13T19:00:00+00:00 TriggerDagRunOperator 2023-05-13T20:11:45.715544+00:00 2023-05-13T20:11:46.185712+00:00 0:00:00.470168 378601 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-13T20:11:42.945896+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-13T19:00:00+00:00 EmrJobFlowSensor 2023-05-13T20:01:03.120649+00:00 2023-05-13T20:11:05.067329+00:00 0:10:01.946680 378594 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-13T20:01:00.851747+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-13T19:00:00+00:00 EmrCreateJobFlowOperator 2023-05-13T20:00:43.337051+00:00 2023-05-13T20:00:44.297924+00:00 0:00:00.960873 378592 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-13T20:00:40.902112+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-13T19:00:00+00:00 PythonOperator 2023-05-13T20:00:21.029544+00:00 2023-05-13T20:00:21.995845+00:00 0:00:00.966301 378590 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-13T20:00:18.812543+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-13T18:00:00+00:00 TriggerDagRunOperator 2023-05-13T19:17:59.006788+00:00 2023-05-13T19:17:59.630456+00:00 0:00:00.623668 378575 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-13T19:17:56.581706+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-13T18:00:00+00:00 TriggerDagRunOperator 2023-05-13T19:17:58.981611+00:00 2023-05-13T19:17:59.668488+00:00 0:00:00.686877 378574 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-13T19:17:56.581677+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-13T18:00:00+00:00 EmrJobFlowSensor 2023-05-13T19:07:47.525509+00:00 2023-05-13T19:17:49.304371+00:00 0:10:01.778862 378570 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-13T19:07:45.294799+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-13T18:00:00+00:00 EmrCreateJobFlowOperator 2023-05-13T19:07:25.433108+00:00 2023-05-13T19:07:26.351095+00:00 0:00:00.917987 378568 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-13T19:07:23.210466+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-13T18:00:00+00:00 PythonOperator 2023-05-13T19:07:05.338641+00:00 2023-05-13T19:07:06.332596+00:00 0:00:00.993955 378565 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-13T19:07:03.189924+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-13T17:00:00+00:00 TriggerDagRunOperator 2023-05-13T18:11:47.636396+00:00 2023-05-13T18:11:48.093232+00:00 0:00:00.456836 378549 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-13T18:11:45.152340+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-13T17:00:00+00:00 TriggerDagRunOperator 2023-05-13T18:11:47.444749+00:00 2023-05-13T18:11:47.791831+00:00 0:00:00.347082 378548 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-13T18:11:45.152370+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-13T17:00:00+00:00 EmrJobFlowSensor 2023-05-13T18:01:40.876738+00:00 2023-05-13T18:11:42.841771+00:00 0:10:01.965033 378541 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-13T18:01:38.522183+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-13T17:00:00+00:00 EmrCreateJobFlowOperator 2023-05-13T18:01:18.662716+00:00 2023-05-13T18:01:19.470782+00:00 0:00:00.808066 378540 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-13T18:01:16.435839+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-13T17:00:00+00:00 PythonOperator 2023-05-13T18:00:58.592040+00:00 2023-05-13T18:00:59.836707+00:00 0:00:01.244667 378539 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-13T18:00:56.417765+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-13T16:00:00+00:00 TriggerDagRunOperator 2023-05-13T17:12:33.223628+00:00 2023-05-13T17:12:33.709167+00:00 0:00:00.485539 378524 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-13T17:12:30.213861+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-13T16:00:00+00:00 TriggerDagRunOperator 2023-05-13T17:12:33.018040+00:00 2023-05-13T17:12:33.370374+00:00 0:00:00.352334 378523 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-13T17:12:30.213830+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-13T16:00:00+00:00 EmrJobFlowSensor 2023-05-13T17:02:24.853394+00:00 2023-05-13T17:12:26.673235+00:00 0:10:01.819841 378515 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-13T17:02:22.694918+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-13T16:00:00+00:00 EmrCreateJobFlowOperator 2023-05-13T17:02:03.376236+00:00 2023-05-13T17:02:04.417397+00:00 0:00:01.041161 378513 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-13T17:02:00.674884+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-13T16:00:00+00:00 PythonOperator 2023-05-13T17:00:04.380964+00:00 2023-05-13T17:00:05.814832+00:00 0:00:01.433868 378511 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-13T17:00:01.200653+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-13T15:00:00+00:00 TriggerDagRunOperator 2023-05-13T16:18:11.619348+00:00 2023-05-13T16:18:12.060412+00:00 0:00:00.441064 378499 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-13T16:18:08.497357+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-13T15:00:00+00:00 TriggerDagRunOperator 2023-05-13T16:18:11.489004+00:00 2023-05-13T16:18:11.829441+00:00 0:00:00.340437 378498 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-13T16:18:08.497391+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-13T15:00:00+00:00 EmrJobFlowSensor 2023-05-13T16:01:56.321106+00:00 2023-05-13T16:11:58.111603+00:00 0:10:01.790497 378491 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-13T16:01:54.154004+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-13T15:00:00+00:00 EmrCreateJobFlowOperator 2023-05-13T16:01:37.061180+00:00 2023-05-13T16:01:38.056988+00:00 0:00:00.995808 378490 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-13T16:01:34.188740+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-13T15:00:00+00:00 PythonOperator 2023-05-13T16:00:13.918501+00:00 2023-05-13T16:00:16.040324+00:00 0:00:02.121823 378486 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-13T16:00:11.600081+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-13T14:00:00+00:00 TriggerDagRunOperator 2023-05-13T15:31:32.191436+00:00 2023-05-13T15:31:32.644976+00:00 0:00:00.453540 378476 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-13T15:31:29.713781+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-13T14:00:00+00:00 TriggerDagRunOperator 2023-05-13T15:31:32.124196+00:00 2023-05-13T15:31:32.457225+00:00 0:00:00.333029 378475 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-13T15:31:29.713753+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-13T14:00:00+00:00 EmrJobFlowSensor 2023-05-13T15:02:41.531137+00:00 2023-05-13T15:12:43.332904+00:00 0:10:01.801767 378468 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-13T15:02:39.297590+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-13T14:00:00+00:00 EmrCreateJobFlowOperator 2023-05-13T15:02:21.331424+00:00 2023-05-13T15:02:22.103565+00:00 0:00:00.772141 378466 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-13T15:02:19.225444+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-13T14:00:00+00:00 PythonOperator 2023-05-13T15:01:59.779846+00:00 2023-05-13T15:02:00.993280+00:00 0:00:01.213434 378464 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-13T15:01:57.215591+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-13T13:00:00+00:00 TriggerDagRunOperator 2023-05-13T14:14:15.691913+00:00 2023-05-13T14:14:16.179592+00:00 0:00:00.487679 378454 airflow-worker-2.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-13T14:14:12.852953+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-13T13:00:00+00:00 TriggerDagRunOperator 2023-05-13T14:14:15.636343+00:00 2023-05-13T14:14:15.973062+00:00 0:00:00.336719 378453 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-13T14:14:12.852912+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-13T13:00:00+00:00 EmrJobFlowSensor 2023-05-13T14:01:51.467592+00:00 2023-05-13T14:11:53.408876+00:00 0:10:01.941284 378446 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-13T14:01:48.713383+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-13T13:00:00+00:00 EmrCreateJobFlowOperator 2023-05-13T14:01:28.839635+00:00 2023-05-13T14:01:29.727206+00:00 0:00:00.887571 378444 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-13T14:01:26.656578+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-13T13:00:00+00:00 PythonOperator 2023-05-13T14:01:08.942303+00:00 2023-05-13T14:01:09.945289+00:00 0:00:01.002986 378442 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-13T14:01:06.641201+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-13T12:00:00+00:00 TriggerDagRunOperator 2023-05-13T13:24:01.872739+00:00 2023-05-13T13:24:02.315493+00:00 0:00:00.442754 378429 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-13T13:23:59.532331+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-13T12:00:00+00:00 TriggerDagRunOperator 2023-05-13T13:24:01.688147+00:00 2023-05-13T13:24:02.036225+00:00 0:00:00.348078 378428 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-13T13:23:59.532367+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-13T12:00:00+00:00 EmrJobFlowSensor 2023-05-13T13:00:48.015575+00:00 2023-05-13T13:10:49.928796+00:00 0:10:01.913221 378423 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-13T13:00:45.807118+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-13T12:00:00+00:00 EmrCreateJobFlowOperator 2023-05-13T13:00:26.868057+00:00 2023-05-13T13:00:27.782874+00:00 0:00:00.914817 378421 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-13T13:00:23.790123+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-13T12:00:00+00:00 PythonOperator 2023-05-13T13:00:06.163867+00:00 2023-05-13T13:00:07.152422+00:00 0:00:00.988555 378419 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-13T13:00:03.729829+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-13T11:00:00+00:00 TriggerDagRunOperator 2023-05-13T12:19:52.149204+00:00 2023-05-13T12:19:52.610554+00:00 0:00:00.461350 378408 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-13T12:19:49.705692+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-13T11:00:00+00:00 TriggerDagRunOperator 2023-05-13T12:19:52.113636+00:00 2023-05-13T12:19:52.467284+00:00 0:00:00.353648 378407 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-13T12:19:49.705662+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-13T11:00:00+00:00 EmrJobFlowSensor 2023-05-13T12:09:42.166364+00:00 2023-05-13T12:19:43.943122+00:00 0:10:01.776758 378402 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-13T12:09:40.008554+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-13T11:00:00+00:00 EmrCreateJobFlowOperator 2023-05-13T12:09:20.479655+00:00 2023-05-13T12:09:21.682429+00:00 0:00:01.202774 378399 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-13T12:09:17.954568+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-13T11:00:00+00:00 PythonOperator 2023-05-13T12:09:00.754798+00:00 2023-05-13T12:09:01.790606+00:00 0:00:01.035808 378397 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-13T12:08:57.950112+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-13T10:00:00+00:00 TriggerDagRunOperator 2023-05-13T11:10:45.462001+00:00 2023-05-13T11:10:45.816454+00:00 0:00:00.354453 378384 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-13T11:10:42.686583+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-13T10:00:00+00:00 TriggerDagRunOperator 2023-05-13T11:10:45.404758+00:00 2023-05-13T11:10:45.878266+00:00 0:00:00.473508 378383 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-13T11:10:42.686540+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-13T10:00:00+00:00 EmrJobFlowSensor 2023-05-13T11:01:38.163547+00:00 2023-05-13T11:10:39.879691+00:00 0:09:01.716144 378377 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-13T11:01:36.018272+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-13T10:00:00+00:00 EmrCreateJobFlowOperator 2023-05-13T11:00:30.686916+00:00 2023-05-13T11:00:31.510500+00:00 0:00:00.823584 378374 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-13T11:00:28.397671+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-13T10:00:00+00:00 PythonOperator 2023-05-13T11:00:10.455595+00:00 2023-05-13T11:00:11.521096+00:00 0:00:01.065501 378372 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-13T11:00:08.310158+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-13T09:00:00+00:00 TriggerDagRunOperator 2023-05-13T10:21:47.922476+00:00 2023-05-13T10:21:48.370745+00:00 0:00:00.448269 378362 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-13T10:21:45.136144+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-13T09:00:00+00:00 TriggerDagRunOperator 2023-05-13T10:21:47.850715+00:00 2023-05-13T10:21:48.194559+00:00 0:00:00.343844 378361 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-13T10:21:45.136117+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-13T09:00:00+00:00 EmrJobFlowSensor 2023-05-13T10:04:39.555498+00:00 2023-05-13T10:14:41.327114+00:00 0:10:01.771616 378354 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-13T10:04:37.184751+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-13T09:00:00+00:00 EmrCreateJobFlowOperator 2023-05-13T10:04:17.335391+00:00 2023-05-13T10:04:18.294206+00:00 0:00:00.958815 378352 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-13T10:04:15.054630+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-13T09:00:00+00:00 PythonOperator 2023-05-13T10:03:56.012268+00:00 2023-05-13T10:03:57.038791+00:00 0:00:01.026523 378350 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-13T10:03:53.030070+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-13T08:00:00+00:00 TriggerDagRunOperator 2023-05-13T09:17:36.669846+00:00 2023-05-13T09:17:36.994593+00:00 0:00:00.324747 378340 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-13T09:17:33.385535+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-13T08:00:00+00:00 TriggerDagRunOperator 2023-05-13T09:17:36.105543+00:00 2023-05-13T09:17:36.574668+00:00 0:00:00.469125 378339 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-13T09:17:33.385563+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-13T08:00:00+00:00 EmrJobFlowSensor 2023-05-13T09:00:49.525021+00:00 2023-05-13T09:10:51.457637+00:00 0:10:01.932616 378332 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-13T09:00:46.171298+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-13T08:00:00+00:00 EmrCreateJobFlowOperator 2023-05-13T09:00:26.348116+00:00 2023-05-13T09:00:27.209472+00:00 0:00:00.861356 378330 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-13T09:00:24.134848+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-13T08:00:00+00:00 PythonOperator 2023-05-13T09:00:04.585692+00:00 2023-05-13T09:00:05.612073+00:00 0:00:01.026381 378328 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-13T09:00:02.112801+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-13T07:00:00+00:00 TriggerDagRunOperator 2023-05-13T08:18:24.165357+00:00 2023-05-13T08:18:24.539299+00:00 0:00:00.373942 378319 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-13T08:18:21.228098+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-13T07:00:00+00:00 TriggerDagRunOperator 2023-05-13T08:18:24.146733+00:00 2023-05-13T08:18:24.624044+00:00 0:00:00.477311 378318 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-13T08:18:21.228070+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-13T07:00:00+00:00 EmrJobFlowSensor 2023-05-13T08:00:54.114304+00:00 2023-05-13T08:10:55.888020+00:00 0:10:01.773716 378310 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-13T08:00:51.804833+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-13T07:00:00+00:00 EmrCreateJobFlowOperator 2023-05-13T08:00:34.082497+00:00 2023-05-13T08:00:35.047914+00:00 0:00:00.965417 378308 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-13T08:00:31.782587+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-13T07:00:00+00:00 PythonOperator 2023-05-13T08:00:12.047045+00:00 2023-05-13T08:00:14.179137+00:00 0:00:02.132092 378306 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-13T08:00:09.684073+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-13T06:00:00+00:00 TriggerDagRunOperator 2023-05-13T07:17:48.810447+00:00 2023-05-13T07:17:49.243345+00:00 0:00:00.432898 378294 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-13T07:17:46.435765+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-13T06:00:00+00:00 TriggerDagRunOperator 2023-05-13T07:17:48.759016+00:00 2023-05-13T07:17:49.125867+00:00 0:00:00.366851 378293 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-13T07:17:46.435793+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-13T06:00:00+00:00 EmrJobFlowSensor 2023-05-13T07:06:41.122122+00:00 2023-05-13T07:17:43.256969+00:00 0:11:02.134847 378288 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-13T07:06:38.744522+00:00 2 default_pool