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-08T06:00:00+00:00 EmrCreateJobFlowOperator 2023-05-08T07:00:34.968934+00:00 2023-05-08T07:00:35.747210+00:00 0:00:00.778276 375209 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-08T07:00:32.529582+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-08T06:00:00+00:00 PythonOperator 2023-05-08T07:00:13.128597+00:00 2023-05-08T07:00:14.119457+00:00 0:00:00.990860 375207 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-08T07:00:10.582683+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-08T05:00:00+00:00 TriggerDagRunOperator 2023-05-08T06:14:22.727932+00:00 2023-05-08T06:14:23.177442+00:00 0:00:00.449510 375194 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-08T06:14:20.155440+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-08T05:00:00+00:00 TriggerDagRunOperator 2023-05-08T06:14:22.651726+00:00 2023-05-08T06:14:22.991627+00:00 0:00:00.339901 375193 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-08T06:14:20.155411+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-08T05:00:00+00:00 EmrJobFlowSensor 2023-05-08T06:03:59.907245+00:00 2023-05-08T06:14:02.230851+00:00 0:10:02.323606 375186 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-08T06:03:57.208544+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-08T05:00:00+00:00 EmrCreateJobFlowOperator 2023-05-08T06:03:37.345405+00:00 2023-05-08T06:03:38.200944+00:00 0:00:00.855539 375184 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-08T06:03:35.112236+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-08T05:00:00+00:00 PythonOperator 2023-05-08T06:03:17.781053+00:00 2023-05-08T06:03:18.773103+00:00 0:00:00.992050 375182 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-08T06:03:15.083875+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-08T04:00:00+00:00 TriggerDagRunOperator 2023-05-08T05:11:21.352185+00:00 2023-05-08T05:11:21.806757+00:00 0:00:00.454572 375168 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-08T05:11:19.006347+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-08T04:00:00+00:00 TriggerDagRunOperator 2023-05-08T05:11:21.266668+00:00 2023-05-08T05:11:21.617608+00:00 0:00:00.350940 375167 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-08T05:11:19.006375+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-08T04:00:00+00:00 EmrJobFlowSensor 2023-05-08T05:00:59.675671+00:00 2023-05-08T05:11:02.008088+00:00 0:10:02.332417 375161 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-08T05:00:57.086115+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-08T04:00:00+00:00 EmrCreateJobFlowOperator 2023-05-08T05:00:37.642913+00:00 2023-05-08T05:00:38.620050+00:00 0:00:00.977137 375159 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-08T05:00:34.936989+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-08T04:00:00+00:00 PythonOperator 2023-05-08T05:00:17.537694+00:00 2023-05-08T05:00:18.581680+00:00 0:00:01.043986 375157 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-08T05:00:14.991358+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-08T03:00:00+00:00 TriggerDagRunOperator 2023-05-08T04:11:36.833706+00:00 2023-05-08T04:11:37.341059+00:00 0:00:00.507353 375142 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-08T04:11:34.392440+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-08T03:00:00+00:00 TriggerDagRunOperator 2023-05-08T04:11:36.763346+00:00 2023-05-08T04:11:37.107984+00:00 0:00:00.344638 375141 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-08T04:11:34.392470+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-08T03:00:00+00:00 EmrJobFlowSensor 2023-05-08T04:01:24.294180+00:00 2023-05-08T04:11:26.254187+00:00 0:10:01.960007 375135 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-08T04:01:21.859945+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-08T03:00:00+00:00 EmrCreateJobFlowOperator 2023-05-08T04:01:02.233962+00:00 2023-05-08T04:01:03.154682+00:00 0:00:00.920720 375133 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-08T04:00:59.902391+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-08T03:00:00+00:00 PythonOperator 2023-05-08T04:00:42.245521+00:00 2023-05-08T04:00:43.238693+00:00 0:00:00.993172 375131 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-08T04:00:39.896954+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-08T02:00:00+00:00 TriggerDagRunOperator 2023-05-08T03:12:22.273829+00:00 2023-05-08T03:12:22.761308+00:00 0:00:00.487479 375117 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-08T03:12:19.208616+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-08T02:00:00+00:00 TriggerDagRunOperator 2023-05-08T03:12:22.227369+00:00 2023-05-08T03:12:22.631316+00:00 0:00:00.403947 375116 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-08T03:12:19.208587+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-08T02:00:00+00:00 EmrJobFlowSensor 2023-05-08T03:00:54.537104+00:00 2023-05-08T03:11:56.495667+00:00 0:11:01.958563 375109 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-08T03:00:51.693208+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-08T02:00:00+00:00 EmrCreateJobFlowOperator 2023-05-08T03:00:33.949971+00:00 2023-05-08T03:00:34.740521+00:00 0:00:00.790550 375107 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-08T03:00:31.682292+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-08T02:00:00+00:00 PythonOperator 2023-05-08T03:00:12.002737+00:00 2023-05-08T03:00:13.236710+00:00 0:00:01.233973 375105 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-08T03:00:09.545887+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-08T01:00:00+00:00 TriggerDagRunOperator 2023-05-08T02:12:13.693420+00:00 2023-05-08T02:12:14.142547+00:00 0:00:00.449127 375091 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-08T02:12:11.146641+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-08T01:00:00+00:00 TriggerDagRunOperator 2023-05-08T02:12:13.635176+00:00 2023-05-08T02:12:14.003303+00:00 0:00:00.368127 375090 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-08T02:12:11.146612+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-08T01:00:00+00:00 EmrJobFlowSensor 2023-05-08T02:01:59.070788+00:00 2023-05-08T02:12:01.129198+00:00 0:10:02.058410 375084 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-08T02:01:56.734099+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-08T01:00:00+00:00 EmrCreateJobFlowOperator 2023-05-08T02:01:39.083700+00:00 2023-05-08T02:01:40.444080+00:00 0:00:01.360380 375082 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-08T02:01:36.686124+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-08T01:00:00+00:00 PythonOperator 2023-05-08T02:00:16.535094+00:00 2023-05-08T02:00:17.517072+00:00 0:00:00.981978 375079 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-08T02:00:14.314615+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-08T00:00:00+00:00 TriggerDagRunOperator 2023-05-08T01:14:24.685912+00:00 2023-05-08T01:14:25.138904+00:00 0:00:00.452992 375058 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-08T01:14:22.215706+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-08T00:00:00+00:00 TriggerDagRunOperator 2023-05-08T01:14:24.563964+00:00 2023-05-08T01:14:24.911142+00:00 0:00:00.347178 375057 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-08T01:14:22.214001+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-08T00:00:00+00:00 EmrJobFlowSensor 2023-05-08T01:14:04.163986+00:00 2023-05-08T01:14:04.645756+00:00 0:00:00.481770 375056 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-08T01:14:02.032274+00:00 3 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-08T00:00:00+00:00 EmrCreateJobFlowOperator 2023-05-08T01:01:27.691587+00:00 2023-05-08T01:01:28.780278+00:00 0:00:01.088691 375048 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-08T01:01:24.072411+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-08T00:00:00+00:00 PythonOperator 2023-05-08T01:00:23.828403+00:00 2023-05-08T01:00:24.820524+00:00 0:00:00.992121 375044 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-08T01:00:21.622511+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-07T23:00:00+00:00 TriggerDagRunOperator 2023-05-08T00:10:57.042463+00:00 2023-05-08T00:10:57.489575+00:00 0:00:00.447112 375030 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-08T00:10:53.995461+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-07T23:00:00+00:00 TriggerDagRunOperator 2023-05-08T00:10:56.940821+00:00 2023-05-08T00:10:57.281708+00:00 0:00:00.340887 375029 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-08T00:10:53.995416+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-07T23:00:00+00:00 EmrJobFlowSensor 2023-05-08T00:01:31.958812+00:00 2023-05-08T00:10:33.747321+00:00 0:09:01.788509 375022 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-08T00:01:28.806735+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-07T23:00:00+00:00 EmrCreateJobFlowOperator 2023-05-08T00:00:35.753252+00:00 2023-05-08T00:00:36.532134+00:00 0:00:00.778882 375020 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-08T00:00:33.296264+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-07T23:00:00+00:00 PythonOperator 2023-05-08T00:00:15.669615+00:00 2023-05-08T00:00:16.671849+00:00 0:00:01.002234 375018 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-08T00:00:13.207388+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-07T22:00:00+00:00 TriggerDagRunOperator 2023-05-07T23:13:15.129288+00:00 2023-05-07T23:13:15.568697+00:00 0:00:00.439409 375003 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-07T23:13:12.510401+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-07T22:00:00+00:00 TriggerDagRunOperator 2023-05-07T23:13:14.940099+00:00 2023-05-07T23:13:15.320310+00:00 0:00:00.380211 375002 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-07T23:13:12.510433+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-07T22:00:00+00:00 EmrJobFlowSensor 2023-05-07T23:12:55.235281+00:00 2023-05-07T23:12:55.723226+00:00 0:00:00.487945 375000 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-07T23:12:52.490043+00:00 3 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-07T22:00:00+00:00 EmrCreateJobFlowOperator 2023-05-07T23:01:02.583211+00:00 2023-05-07T23:01:03.432916+00:00 0:00:00.849705 374990 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-07T23:00:59.690179+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-07T22:00:00+00:00 PythonOperator 2023-05-07T23:00:24.514315+00:00 2023-05-07T23:00:25.413919+00:00 0:00:00.899604 374987 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-07T23:00:21.904238+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-07T21:00:00+00:00 TriggerDagRunOperator 2023-05-07T22:10:40.791180+00:00 2023-05-07T22:10:41.150775+00:00 0:00:00.359595 374972 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-07T22:10:37.674347+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-07T21:00:00+00:00 TriggerDagRunOperator 2023-05-07T22:10:40.668827+00:00 2023-05-07T22:10:41.174870+00:00 0:00:00.506043 374971 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-07T22:10:37.674319+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-07T21:00:00+00:00 EmrJobFlowSensor 2023-05-07T22:01:17.176600+00:00 2023-05-07T22:10:18.893679+00:00 0:09:01.717079 374965 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-07T22:01:14.918869+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-07T21:00:00+00:00 EmrCreateJobFlowOperator 2023-05-07T22:00:26.645939+00:00 2023-05-07T22:00:27.457486+00:00 0:00:00.811547 374961 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-07T22:00:24.450496+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-07T21:00:00+00:00 PythonOperator 2023-05-07T22:00:04.815603+00:00 2023-05-07T22:00:05.858389+00:00 0:00:01.042786 374959 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-07T22:00:02.430024+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-07T20:00:00+00:00 TriggerDagRunOperator 2023-05-07T21:11:37.651666+00:00 2023-05-07T21:11:38.104266+00:00 0:00:00.452600 374946 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-07T21:11:35.112990+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-07T20:00:00+00:00 TriggerDagRunOperator 2023-05-07T21:11:37.626983+00:00 2023-05-07T21:11:37.974238+00:00 0:00:00.347255 374945 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-07T21:11:35.112961+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-07T20:00:00+00:00 EmrJobFlowSensor 2023-05-07T21:01:22.134421+00:00 2023-05-07T21:11:23.894808+00:00 0:10:01.760387 374938 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-07T21:01:19.971386+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-07T20:00:00+00:00 EmrCreateJobFlowOperator 2023-05-07T21:01:02.344452+00:00 2023-05-07T21:01:03.233276+00:00 0:00:00.888824 374936 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-07T21:00:59.965109+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-07T20:00:00+00:00 PythonOperator 2023-05-07T21:00:21.070683+00:00 2023-05-07T21:00:22.351566+00:00 0:00:01.280883 374934 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-07T21:00:18.521518+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-07T19:00:00+00:00 TriggerDagRunOperator 2023-05-07T20:11:56.409103+00:00 2023-05-07T20:11:56.853695+00:00 0:00:00.444592 374920 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-07T20:11:53.918918+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-07T19:00:00+00:00 TriggerDagRunOperator 2023-05-07T20:11:56.318656+00:00 2023-05-07T20:11:56.676526+00:00 0:00:00.357870 374919 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-07T20:11:53.918877+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-07T19:00:00+00:00 EmrJobFlowSensor 2023-05-07T20:01:31.725260+00:00 2023-05-07T20:11:33.514570+00:00 0:10:01.789310 374914 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-07T20:01:29.501970+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-07T19:00:00+00:00 EmrCreateJobFlowOperator 2023-05-07T20:01:11.728505+00:00 2023-05-07T20:01:12.572337+00:00 0:00:00.843832 374912 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-07T20:01:09.483277+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-07T19:00:00+00:00 PythonOperator 2023-05-07T20:00:18.255872+00:00 2023-05-07T20:00:19.344016+00:00 0:00:01.088144 374908 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-07T20:00:16.015693+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-07T18:00:00+00:00 TriggerDagRunOperator 2023-05-07T19:11:52.753968+00:00 2023-05-07T19:11:53.204253+00:00 0:00:00.450285 374892 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-07T19:11:50.410722+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-07T18:00:00+00:00 TriggerDagRunOperator 2023-05-07T19:11:52.737266+00:00 2023-05-07T19:11:53.098244+00:00 0:00:00.360978 374891 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-07T19:11:50.410684+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-07T18:00:00+00:00 EmrJobFlowSensor 2023-05-07T19:01:43.330174+00:00 2023-05-07T19:11:45.310791+00:00 0:10:01.980617 374884 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-07T19:01:41.156937+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-07T18:00:00+00:00 EmrCreateJobFlowOperator 2023-05-07T19:01:21.963151+00:00 2023-05-07T19:01:23.004650+00:00 0:00:01.041499 374883 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-07T19:01:19.019709+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-07T18:00:00+00:00 PythonOperator 2023-05-07T19:00:17.474817+00:00 2023-05-07T19:00:18.573594+00:00 0:00:01.098777 374880 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-07T19:00:15.027512+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-07T17:00:00+00:00 TriggerDagRunOperator 2023-05-07T18:11:43.099177+00:00 2023-05-07T18:11:43.605017+00:00 0:00:00.505840 374863 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-07T18:11:40.838146+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-07T17:00:00+00:00 TriggerDagRunOperator 2023-05-07T18:11:43.052571+00:00 2023-05-07T18:11:43.442744+00:00 0:00:00.390173 374862 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-07T18:11:40.838107+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-07T17:00:00+00:00 EmrJobFlowSensor 2023-05-07T18:01:29.649020+00:00 2023-05-07T18:11:31.692269+00:00 0:10:02.043249 374855 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-07T18:01:27.452668+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-07T17:00:00+00:00 EmrCreateJobFlowOperator 2023-05-07T18:01:09.923164+00:00 2023-05-07T18:01:10.770002+00:00 0:00:00.846838 374854 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-07T18:01:07.533129+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-07T17:00:00+00:00 PythonOperator 2023-05-07T18:00:47.955308+00:00 2023-05-07T18:00:48.896484+00:00 0:00:00.941176 374852 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-07T18:00:45.457615+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-07T16:00:00+00:00 TriggerDagRunOperator 2023-05-07T17:11:30.347446+00:00 2023-05-07T17:11:30.800755+00:00 0:00:00.453309 374838 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-07T17:11:27.387075+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-07T16:00:00+00:00 TriggerDagRunOperator 2023-05-07T17:11:30.323560+00:00 2023-05-07T17:11:30.805365+00:00 0:00:00.481805 374837 airflow-worker-2.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-07T17:11:27.387030+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-07T16:00:00+00:00 EmrJobFlowSensor 2023-05-07T17:01:03.656340+00:00 2023-05-07T17:11:05.517497+00:00 0:10:01.861157 374827 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-07T17:01:01.112633+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-07T16:00:00+00:00 EmrCreateJobFlowOperator 2023-05-07T17:00:43.263251+00:00 2023-05-07T17:00:44.126795+00:00 0:00:00.863544 374826 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-07T17:00:41.037809+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-07T16:00:00+00:00 PythonOperator 2023-05-07T17:00:21.748745+00:00 2023-05-07T17:00:22.761091+00:00 0:00:01.012346 374825 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-07T17:00:19.017687+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-07T15:00:00+00:00 TriggerDagRunOperator 2023-05-07T16:15:51.716716+00:00 2023-05-07T16:15:52.071367+00:00 0:00:00.354651 374808 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-07T16:15:47.917025+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-07T15:00:00+00:00 TriggerDagRunOperator 2023-05-07T16:15:50.232266+00:00 2023-05-07T16:15:50.680384+00:00 0:00:00.448118 374807 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-07T16:15:47.917060+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-07T15:00:00+00:00 EmrJobFlowSensor 2023-05-07T16:00:46.667562+00:00 2023-05-07T16:10:48.450248+00:00 0:10:01.782686 374804 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-07T16:00:44.211260+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-07T15:00:00+00:00 EmrCreateJobFlowOperator 2023-05-07T16:00:26.449390+00:00 2023-05-07T16:00:27.237087+00:00 0:00:00.787697 374803 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-07T16:00:24.192663+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-07T15:00:00+00:00 PythonOperator 2023-05-07T16:00:04.674594+00:00 2023-05-07T16:00:05.696655+00:00 0:00:01.022061 374801 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-07T16:00:02.119035+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-07T14:00:00+00:00 TriggerDagRunOperator 2023-05-07T15:15:03.320810+00:00 2023-05-07T15:15:03.796059+00:00 0:00:00.475249 374787 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-07T15:15:00.288090+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-07T14:00:00+00:00 TriggerDagRunOperator 2023-05-07T15:15:03.254417+00:00 2023-05-07T15:15:03.699191+00:00 0:00:00.444774 374786 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-07T15:15:00.288152+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-07T14:00:00+00:00 EmrJobFlowSensor 2023-05-07T15:01:02.349223+00:00 2023-05-07T15:11:04.190169+00:00 0:10:01.840946 374783 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-07T15:01:00.174197+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-07T14:00:00+00:00 EmrCreateJobFlowOperator 2023-05-07T15:00:42.438278+00:00 2023-05-07T15:00:43.198276+00:00 0:00:00.759998 374781 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-07T15:00:40.121073+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-07T14:00:00+00:00 PythonOperator 2023-05-07T15:00:18.439306+00:00 2023-05-07T15:00:19.511849+00:00 0:00:01.072543 374779 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-07T15:00:16.107501+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-07T13:00:00+00:00 TriggerDagRunOperator 2023-05-07T14:16:28.180984+00:00 2023-05-07T14:16:28.671998+00:00 0:00:00.491014 374768 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-07T14:16:25.255610+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-07T13:00:00+00:00 TriggerDagRunOperator 2023-05-07T14:16:28.048367+00:00 2023-05-07T14:16:28.414858+00:00 0:00:00.366491 374767 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-07T14:16:25.255638+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-07T13:00:00+00:00 EmrJobFlowSensor 2023-05-07T14:03:41.843495+00:00 2023-05-07T14:13:43.887647+00:00 0:10:02.044152 374761 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-07T14:03:39.611161+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-07T13:00:00+00:00 EmrCreateJobFlowOperator 2023-05-07T14:03:19.857853+00:00 2023-05-07T14:03:20.879282+00:00 0:00:01.021429 374759 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-07T14:03:17.576564+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-07T13:00:00+00:00 PythonOperator 2023-05-07T14:02:59.827746+00:00 2023-05-07T14:03:00.926458+00:00 0:00:01.098712 374757 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-07T14:02:57.557769+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-07T12:00:00+00:00 TriggerDagRunOperator 2023-05-07T13:20:53.493418+00:00 2023-05-07T13:20:54.008070+00:00 0:00:00.514652 374746 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-07T13:20:50.680730+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-07T12:00:00+00:00 TriggerDagRunOperator 2023-05-07T13:20:53.434924+00:00 2023-05-07T13:20:53.810461+00:00 0:00:00.375537 374745 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-07T13:20:50.680781+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-07T12:00:00+00:00 EmrJobFlowSensor 2023-05-07T13:10:45.345579+00:00 2023-05-07T13:20:47.114567+00:00 0:10:01.768988 374741 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-07T13:10:42.994281+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-07T12:00:00+00:00 EmrCreateJobFlowOperator 2023-05-07T13:10:23.203631+00:00 2023-05-07T13:10:24.503982+00:00 0:00:01.300351 374738 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-07T13:10:20.906922+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-07T12:00:00+00:00 PythonOperator 2023-05-07T13:10:03.161602+00:00 2023-05-07T13:10:04.214672+00:00 0:00:01.053070 374735 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-07T13:10:00.878418+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-07T11:00:00+00:00 TriggerDagRunOperator 2023-05-07T12:25:33.568904+00:00 2023-05-07T12:25:34.017819+00:00 0:00:00.448915 374725 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-07T12:25:30.711002+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-07T11:00:00+00:00 TriggerDagRunOperator 2023-05-07T12:25:33.440152+00:00 2023-05-07T12:25:33.815501+00:00 0:00:00.375349 374724 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-07T12:25:30.710971+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-07T11:00:00+00:00 EmrJobFlowSensor 2023-05-07T12:06:19.718001+00:00 2023-05-07T12:16:21.727157+00:00 0:10:02.009156 374721 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-07T12:06:14.793045+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-07T11:00:00+00:00 EmrCreateJobFlowOperator 2023-05-07T12:05:56.936186+00:00 2023-05-07T12:05:57.875400+00:00 0:00:00.939214 374717 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-07T12:05:54.729572+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-07T11:00:00+00:00 PythonOperator 2023-05-07T12:05:37.540632+00:00 2023-05-07T12:05:39.074067+00:00 0:00:01.533435 374714 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-07T12:05:32.579598+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-07T10:00:00+00:00 TriggerDagRunOperator 2023-05-07T11:12:08.314446+00:00 2023-05-07T11:12:08.951790+00:00 0:00:00.637344 374701 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-07T11:12:05.627875+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-07T10:00:00+00:00 TriggerDagRunOperator 2023-05-07T11:12:08.249867+00:00 2023-05-07T11:12:08.833330+00:00 0:00:00.583463 374700 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-07T11:12:05.627904+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-07T10:00:00+00:00 EmrJobFlowSensor 2023-05-07T11:00:55.093642+00:00 2023-05-07T11:10:57.020201+00:00 0:10:01.926559 374693 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-07T11:00:52.753042+00:00 2 default_pool