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-06-22T01:00:00+00:00 EmrCreateJobFlowOperator 2023-06-22T02:00:39.941775+00:00 2023-06-22T02:00:40.863169+00:00 0:00:00.921394 395904 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-22T02:00:37.984205+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-22T01:00:00+00:00 PythonOperator 2023-06-22T02:00:20.060429+00:00 2023-06-22T02:00:21.336493+00:00 0:00:01.276064 395902 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-22T02:00:17.967228+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-22T00:00:00+00:00 TriggerDagRunOperator 2023-06-22T01:11:17.859588+00:00 2023-06-22T01:11:18.325089+00:00 0:00:00.465501 395884 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-22T01:11:15.462642+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-22T00:00:00+00:00 TriggerDagRunOperator 2023-06-22T01:11:17.616954+00:00 2023-06-22T01:11:18.030329+00:00 0:00:00.413375 395883 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-22T01:11:15.462616+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-22T00:00:00+00:00 EmrJobFlowSensor 2023-06-22T01:00:53.318292+00:00 2023-06-22T01:10:55.201791+00:00 0:10:01.883499 395876 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-22T01:00:51.000837+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-22T00:00:00+00:00 EmrCreateJobFlowOperator 2023-06-22T01:00:32.894021+00:00 2023-06-22T01:00:33.856858+00:00 0:00:00.962837 395874 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-22T01:00:30.980917+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-22T00:00:00+00:00 PythonOperator 2023-06-22T01:00:11.376193+00:00 2023-06-22T01:00:12.202800+00:00 0:00:00.826607 395872 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-22T01:00:08.965367+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-21T23:00:00+00:00 TriggerDagRunOperator 2023-06-22T00:11:30.798501+00:00 2023-06-22T00:11:31.269481+00:00 0:00:00.470980 395861 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-22T00:11:28.149098+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-21T23:00:00+00:00 TriggerDagRunOperator 2023-06-22T00:11:30.415764+00:00 2023-06-22T00:11:30.816036+00:00 0:00:00.400272 395860 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-22T00:11:28.149072+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-21T23:00:00+00:00 EmrJobFlowSensor 2023-06-22T00:01:03.129128+00:00 2023-06-22T00:11:05.143726+00:00 0:10:02.014598 395854 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-22T00:01:00.889862+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-21T23:00:00+00:00 EmrCreateJobFlowOperator 2023-06-22T00:00:42.868201+00:00 2023-06-22T00:00:43.755375+00:00 0:00:00.887174 395852 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-22T00:00:40.872702+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-21T23:00:00+00:00 PythonOperator 2023-06-22T00:00:20.745410+00:00 2023-06-22T00:00:21.639134+00:00 0:00:00.893724 395850 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-22T00:00:18.852764+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-21T22:00:00+00:00 TriggerDagRunOperator 2023-06-21T23:11:13.946431+00:00 2023-06-21T23:11:14.386615+00:00 0:00:00.440184 395838 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-21T23:11:11.593736+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-21T22:00:00+00:00 TriggerDagRunOperator 2023-06-21T23:11:13.628907+00:00 2023-06-21T23:11:14.049587+00:00 0:00:00.420680 395837 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-21T23:11:11.593709+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-21T22:00:00+00:00 EmrJobFlowSensor 2023-06-21T23:01:00.816972+00:00 2023-06-21T23:11:02.829402+00:00 0:10:02.012430 395830 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-21T23:00:58.571659+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-21T22:00:00+00:00 EmrCreateJobFlowOperator 2023-06-21T23:00:40.429022+00:00 2023-06-21T23:00:41.386551+00:00 0:00:00.957529 395827 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-21T23:00:38.553808+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-21T22:00:00+00:00 PythonOperator 2023-06-21T23:00:18.459449+00:00 2023-06-21T23:00:19.325897+00:00 0:00:00.866448 395824 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-21T23:00:16.531443+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-21T21:00:00+00:00 TriggerDagRunOperator 2023-06-21T22:11:28.112931+00:00 2023-06-21T22:11:28.568567+00:00 0:00:00.455636 395812 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-21T22:11:25.709090+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-21T21:00:00+00:00 TriggerDagRunOperator 2023-06-21T22:11:27.771765+00:00 2023-06-21T22:11:28.167364+00:00 0:00:00.395599 395811 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-21T22:11:25.709054+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-21T21:00:00+00:00 EmrJobFlowSensor 2023-06-21T22:01:02.124823+00:00 2023-06-21T22:11:04.160212+00:00 0:10:02.035389 395804 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-21T22:00:59.846348+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-21T21:00:00+00:00 EmrCreateJobFlowOperator 2023-06-21T22:00:39.734063+00:00 2023-06-21T22:00:40.717969+00:00 0:00:00.983906 395802 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-21T22:00:37.796690+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-21T21:00:00+00:00 PythonOperator 2023-06-21T22:00:20.123118+00:00 2023-06-21T22:00:21.080166+00:00 0:00:00.957048 395800 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-21T22:00:17.780140+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-21T20:00:00+00:00 TriggerDagRunOperator 2023-06-21T21:10:59.042553+00:00 2023-06-21T21:10:59.501245+00:00 0:00:00.458692 395789 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-21T21:10:56.668946+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-21T20:00:00+00:00 TriggerDagRunOperator 2023-06-21T21:10:58.719565+00:00 2023-06-21T21:10:59.149636+00:00 0:00:00.430071 395788 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-21T21:10:56.668975+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-21T20:00:00+00:00 EmrJobFlowSensor 2023-06-21T21:00:52.163179+00:00 2023-06-21T21:10:54.039038+00:00 0:10:01.875859 395782 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-21T21:00:49.838206+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-21T20:00:00+00:00 EmrCreateJobFlowOperator 2023-06-21T21:00:32.034536+00:00 2023-06-21T21:00:32.914870+00:00 0:00:00.880334 395780 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-21T21:00:29.793934+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-21T20:00:00+00:00 PythonOperator 2023-06-21T21:00:09.959245+00:00 2023-06-21T21:00:11.016004+00:00 0:00:01.056759 395778 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-21T21:00:07.772118+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-21T19:00:00+00:00 TriggerDagRunOperator 2023-06-21T20:11:22.628234+00:00 2023-06-21T20:11:23.113831+00:00 0:00:00.485597 395765 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-21T20:11:20.333112+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-21T19:00:00+00:00 TriggerDagRunOperator 2023-06-21T20:11:22.384326+00:00 2023-06-21T20:11:22.783240+00:00 0:00:00.398914 395764 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-21T20:11:20.333074+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-21T19:00:00+00:00 EmrJobFlowSensor 2023-06-21T20:01:03.219237+00:00 2023-06-21T20:11:05.188074+00:00 0:10:01.968837 395758 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-21T20:01:00.990286+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-21T19:00:00+00:00 EmrCreateJobFlowOperator 2023-06-21T20:00:42.874953+00:00 2023-06-21T20:00:43.787399+00:00 0:00:00.912446 395756 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-21T20:00:40.930420+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-21T19:00:00+00:00 PythonOperator 2023-06-21T20:00:21.192789+00:00 2023-06-21T20:00:22.154093+00:00 0:00:00.961304 395754 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-21T20:00:18.886373+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-21T18:00:00+00:00 TriggerDagRunOperator 2023-06-21T19:11:24.421285+00:00 2023-06-21T19:11:24.865195+00:00 0:00:00.443910 395740 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-21T19:11:22.128781+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-21T18:00:00+00:00 TriggerDagRunOperator 2023-06-21T19:11:24.121434+00:00 2023-06-21T19:11:24.530543+00:00 0:00:00.409109 395739 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-21T19:11:22.128812+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-21T18:00:00+00:00 EmrJobFlowSensor 2023-06-21T19:00:58.522599+00:00 2023-06-21T19:11:00.441390+00:00 0:10:01.918791 395732 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-21T19:00:56.354232+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-21T18:00:00+00:00 EmrCreateJobFlowOperator 2023-06-21T19:00:36.588741+00:00 2023-06-21T19:00:37.610152+00:00 0:00:01.021411 395731 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-21T19:00:34.335416+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-21T18:00:00+00:00 PythonOperator 2023-06-21T19:00:16.540186+00:00 2023-06-21T19:00:17.403141+00:00 0:00:00.862955 395729 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-21T19:00:14.319191+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-21T17:00:00+00:00 TriggerDagRunOperator 2023-06-21T18:10:58.422446+00:00 2023-06-21T18:10:58.936355+00:00 0:00:00.513909 395716 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-21T18:10:56.226023+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-21T17:00:00+00:00 TriggerDagRunOperator 2023-06-21T18:10:58.351795+00:00 2023-06-21T18:10:58.751854+00:00 0:00:00.400059 395715 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-21T18:10:56.226054+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-21T17:00:00+00:00 EmrJobFlowSensor 2023-06-21T18:00:51.949832+00:00 2023-06-21T18:10:53.736543+00:00 0:10:01.786711 395708 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-21T18:00:50.055551+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-21T17:00:00+00:00 EmrCreateJobFlowOperator 2023-06-21T18:00:32.300197+00:00 2023-06-21T18:00:33.280906+00:00 0:00:00.980709 395707 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-21T18:00:30.054462+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-21T17:00:00+00:00 PythonOperator 2023-06-21T18:00:10.209048+00:00 2023-06-21T18:00:11.204986+00:00 0:00:00.995938 395706 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-21T18:00:08.017600+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-21T16:00:00+00:00 TriggerDagRunOperator 2023-06-21T17:11:27.195358+00:00 2023-06-21T17:11:27.659205+00:00 0:00:00.463847 395694 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-21T17:11:24.732477+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-21T16:00:00+00:00 TriggerDagRunOperator 2023-06-21T17:11:26.729880+00:00 2023-06-21T17:11:27.148705+00:00 0:00:00.418825 395693 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-21T17:11:24.732452+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-21T16:00:00+00:00 EmrJobFlowSensor 2023-06-21T17:01:01.790694+00:00 2023-06-21T17:11:03.806124+00:00 0:10:02.015430 395684 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-21T17:00:59.585858+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-21T16:00:00+00:00 EmrCreateJobFlowOperator 2023-06-21T17:00:39.461294+00:00 2023-06-21T17:00:40.394281+00:00 0:00:00.932987 395683 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-21T17:00:37.566441+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-21T16:00:00+00:00 PythonOperator 2023-06-21T17:00:19.845348+00:00 2023-06-21T17:00:20.713745+00:00 0:00:00.868397 395681 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-21T17:00:17.603089+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-21T15:00:00+00:00 TriggerDagRunOperator 2023-06-21T16:12:19.457713+00:00 2023-06-21T16:12:19.916218+00:00 0:00:00.458505 395670 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-21T16:12:17.043643+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-21T15:00:00+00:00 TriggerDagRunOperator 2023-06-21T16:12:19.234997+00:00 2023-06-21T16:12:19.631589+00:00 0:00:00.396592 395669 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-21T16:12:17.043671+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-21T15:00:00+00:00 EmrJobFlowSensor 2023-06-21T16:02:03.465134+00:00 2023-06-21T16:12:05.262297+00:00 0:10:01.797163 395663 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-21T16:02:01.434768+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-21T15:00:00+00:00 EmrCreateJobFlowOperator 2023-06-21T16:01:43.617716+00:00 2023-06-21T16:01:44.584660+00:00 0:00:00.966944 395661 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-21T16:01:41.414292+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-21T15:00:00+00:00 PythonOperator 2023-06-21T16:01:21.393695+00:00 2023-06-21T16:01:22.246152+00:00 0:00:00.852457 395659 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-21T16:01:19.392764+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-21T14:00:00+00:00 TriggerDagRunOperator 2023-06-21T15:17:57.008739+00:00 2023-06-21T15:17:57.449954+00:00 0:00:00.441215 395649 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-21T15:17:54.607626+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-21T14:00:00+00:00 TriggerDagRunOperator 2023-06-21T15:17:56.736325+00:00 2023-06-21T15:17:57.166981+00:00 0:00:00.430656 395648 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-21T15:17:54.607598+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-21T14:00:00+00:00 EmrJobFlowSensor 2023-06-21T15:00:58.932858+00:00 2023-06-21T15:11:00.854171+00:00 0:10:01.921313 395640 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-21T15:00:56.744013+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-21T14:00:00+00:00 EmrCreateJobFlowOperator 2023-06-21T15:00:38.640869+00:00 2023-06-21T15:00:39.531051+00:00 0:00:00.890182 395638 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-21T15:00:36.718231+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-21T14:00:00+00:00 PythonOperator 2023-06-21T15:00:16.672582+00:00 2023-06-21T15:00:17.583582+00:00 0:00:00.911000 395636 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-21T15:00:14.648684+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-21T13:00:00+00:00 TriggerDagRunOperator 2023-06-21T14:23:05.418328+00:00 2023-06-21T14:23:05.806475+00:00 0:00:00.388147 395627 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-21T14:23:02.921488+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-21T13:00:00+00:00 TriggerDagRunOperator 2023-06-21T14:23:05.217372+00:00 2023-06-21T14:23:05.692784+00:00 0:00:00.475412 395626 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-21T14:23:02.921456+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-21T13:00:00+00:00 EmrJobFlowSensor 2023-06-21T14:01:02.982173+00:00 2023-06-21T14:11:04.962253+00:00 0:10:01.980080 395622 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-21T14:01:00.687743+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-21T13:00:00+00:00 EmrCreateJobFlowOperator 2023-06-21T14:00:41.170181+00:00 2023-06-21T14:00:42.159288+00:00 0:00:00.989107 395620 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-21T14:00:38.665176+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-21T13:00:00+00:00 PythonOperator 2023-06-21T14:00:19.046211+00:00 2023-06-21T14:00:20.068958+00:00 0:00:01.022747 395618 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-21T14:00:16.654651+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-21T12:00:00+00:00 TriggerDagRunOperator 2023-06-21T13:23:48.989576+00:00 2023-06-21T13:23:49.789890+00:00 0:00:00.800314 395607 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-21T13:23:46.364368+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-21T12:00:00+00:00 TriggerDagRunOperator 2023-06-21T13:23:48.553732+00:00 2023-06-21T13:23:49.014531+00:00 0:00:00.460799 395606 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-21T13:23:46.364340+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-21T12:00:00+00:00 EmrJobFlowSensor 2023-06-21T13:00:57.997900+00:00 2023-06-21T13:10:59.903473+00:00 0:10:01.905573 395603 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-21T13:00:55.616822+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-21T12:00:00+00:00 EmrCreateJobFlowOperator 2023-06-21T13:00:37.830137+00:00 2023-06-21T13:00:38.839858+00:00 0:00:01.009721 395601 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-21T13:00:35.596252+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-21T12:00:00+00:00 PythonOperator 2023-06-21T13:00:15.848872+00:00 2023-06-21T13:00:16.888158+00:00 0:00:01.039286 395599 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-21T13:00:13.573776+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-21T11:00:00+00:00 TriggerDagRunOperator 2023-06-21T12:17:38.622976+00:00 2023-06-21T12:17:39.104206+00:00 0:00:00.481230 395592 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-21T12:17:36.170298+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-21T11:00:00+00:00 TriggerDagRunOperator 2023-06-21T12:17:38.333450+00:00 2023-06-21T12:17:38.731101+00:00 0:00:00.397651 395591 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-21T12:17:36.170270+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-21T11:00:00+00:00 EmrJobFlowSensor 2023-06-21T12:04:27.772561+00:00 2023-06-21T12:14:29.565858+00:00 0:10:01.793297 395585 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-21T12:04:25.789351+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-21T11:00:00+00:00 EmrCreateJobFlowOperator 2023-06-21T12:04:05.718126+00:00 2023-06-21T12:04:06.621676+00:00 0:00:00.903550 395583 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-21T12:04:03.766546+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-21T11:00:00+00:00 PythonOperator 2023-06-21T12:03:46.080157+00:00 2023-06-21T12:03:47.079202+00:00 0:00:00.999045 395581 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-21T12:03:43.750372+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-21T10:00:00+00:00 TriggerDagRunOperator 2023-06-21T11:12:35.854758+00:00 2023-06-21T11:12:36.487500+00:00 0:00:00.632742 395572 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-21T11:12:33.504726+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-21T10:00:00+00:00 TriggerDagRunOperator 2023-06-21T11:12:35.622122+00:00 2023-06-21T11:12:36.115605+00:00 0:00:00.493483 395571 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-21T11:12:33.504698+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-21T10:00:00+00:00 EmrJobFlowSensor 2023-06-21T11:02:10.734211+00:00 2023-06-21T11:12:12.462435+00:00 0:10:01.728224 395564 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-21T11:02:08.849267+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-21T10:00:00+00:00 EmrCreateJobFlowOperator 2023-06-21T11:01:48.739111+00:00 2023-06-21T11:01:49.672359+00:00 0:00:00.933248 395562 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-21T11:01:46.829521+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-21T10:00:00+00:00 PythonOperator 2023-06-21T11:00:15.700831+00:00 2023-06-21T11:00:16.697559+00:00 0:00:00.996728 395559 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-21T11:00:13.276367+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-21T09:00:00+00:00 TriggerDagRunOperator 2023-06-21T10:11:22.364212+00:00 2023-06-21T10:11:22.847532+00:00 0:00:00.483320 395550 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-21T10:11:19.937249+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-21T09:00:00+00:00 TriggerDagRunOperator 2023-06-21T10:11:22.068930+00:00 2023-06-21T10:11:22.498479+00:00 0:00:00.429549 395549 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-21T10:11:19.937221+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-21T09:00:00+00:00 EmrJobFlowSensor 2023-06-21T10:01:06.452597+00:00 2023-06-21T10:11:08.111901+00:00 0:10:01.659304 395543 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-21T10:01:04.558962+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-21T09:00:00+00:00 EmrCreateJobFlowOperator 2023-06-21T10:00:46.863626+00:00 2023-06-21T10:00:47.824960+00:00 0:00:00.961334 395541 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-21T10:00:44.537825+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-21T09:00:00+00:00 PythonOperator 2023-06-21T10:00:24.790738+00:00 2023-06-21T10:00:25.707324+00:00 0:00:00.916586 395539 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-21T10:00:22.516702+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-21T08:00:00+00:00 TriggerDagRunOperator 2023-06-21T09:20:34.014392+00:00 2023-06-21T09:20:34.481745+00:00 0:00:00.467353 395529 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-21T09:20:31.620515+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-21T08:00:00+00:00 TriggerDagRunOperator 2023-06-21T09:20:33.722224+00:00 2023-06-21T09:20:34.140340+00:00 0:00:00.418116 395528 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-21T09:20:31.620544+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-21T08:00:00+00:00 EmrJobFlowSensor 2023-06-21T09:07:42.750446+00:00 2023-06-21T09:18:44.625236+00:00 0:11:01.874790 395525 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-21T09:07:40.748816+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-21T08:00:00+00:00 EmrCreateJobFlowOperator 2023-06-21T09:07:22.921072+00:00 2023-06-21T09:07:23.949289+00:00 0:00:01.028217 395522 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-21T09:07:20.730650+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-21T08:00:00+00:00 PythonOperator 2023-06-21T09:07:00.993754+00:00 2023-06-21T09:07:02.007219+00:00 0:00:01.013465 395519 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-21T09:06:58.711954+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-21T07:00:00+00:00 TriggerDagRunOperator 2023-06-21T08:11:02.368605+00:00 2023-06-21T08:11:02.852497+00:00 0:00:00.483892 395505 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-21T08:10:59.978045+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-21T07:00:00+00:00 TriggerDagRunOperator 2023-06-21T08:11:02.029458+00:00 2023-06-21T08:11:02.418765+00:00 0:00:00.389307 395504 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-21T08:10:59.978072+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-21T07:00:00+00:00 EmrJobFlowSensor 2023-06-21T08:00:53.640033+00:00 2023-06-21T08:10:55.482087+00:00 0:10:01.842054 395496 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-21T08:00:51.689562+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-21T07:00:00+00:00 EmrCreateJobFlowOperator 2023-06-21T08:00:31.973893+00:00 2023-06-21T08:00:32.936691+00:00 0:00:00.962798 395494 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-21T08:00:29.667384+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-21T07:00:00+00:00 PythonOperator 2023-06-21T08:00:10.182545+00:00 2023-06-21T08:00:11.598783+00:00 0:00:01.416238 395492 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-21T08:00:07.647453+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-21T06:00:00+00:00 TriggerDagRunOperator 2023-06-21T07:12:22.292722+00:00 2023-06-21T07:12:22.753607+00:00 0:00:00.460885 395476 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-21T07:12:19.830091+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-21T06:00:00+00:00 TriggerDagRunOperator 2023-06-21T07:12:21.760219+00:00 2023-06-21T07:12:22.244410+00:00 0:00:00.484191 395475 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-21T07:12:19.830124+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-21T06:00:00+00:00 EmrJobFlowSensor 2023-06-21T07:01:04.176110+00:00 2023-06-21T07:12:06.049153+00:00 0:11:01.873043 395469 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-21T07:01:02.186767+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-21T06:00:00+00:00 EmrCreateJobFlowOperator 2023-06-21T07:00:44.262015+00:00 2023-06-21T07:00:45.141590+00:00 0:00:00.879575 395467 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-21T07:00:42.223028+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-21T06:00:00+00:00 PythonOperator 2023-06-21T07:00:22.442023+00:00 2023-06-21T07:00:23.435135+00:00 0:00:00.993112 395465 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-21T07:00:20.144682+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-21T05:00:00+00:00 TriggerDagRunOperator 2023-06-21T06:11:20.215480+00:00 2023-06-21T06:11:20.665052+00:00 0:00:00.449572 395453 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-21T06:11:17.642995+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-21T05:00:00+00:00 TriggerDagRunOperator 2023-06-21T06:11:19.917930+00:00 2023-06-21T06:11:20.319168+00:00 0:00:00.401238 395452 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-21T06:11:17.642968+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-21T05:00:00+00:00 EmrJobFlowSensor 2023-06-21T06:00:59.895787+00:00 2023-06-21T06:11:01.864016+00:00 0:10:01.968229 395445 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-21T06:00:57.525585+00:00 2 default_pool