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-18T06:00:00+00:00 EmrCreateJobFlowOperator 2023-05-18T07:00:42.805787+00:00 2023-05-18T07:00:43.806374+00:00 0:00:01.000587 381347 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-18T07:00:40.598181+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-18T06:00:00+00:00 PythonOperator 2023-05-18T07:00:21.214023+00:00 2023-05-18T07:00:22.297662+00:00 0:00:01.083639 381345 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-18T07:00:18.578438+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-18T05:00:00+00:00 TriggerDagRunOperator 2023-05-18T06:11:21.278404+00:00 2023-05-18T06:11:21.732337+00:00 0:00:00.453933 381332 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-18T06:11:18.847535+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-18T05:00:00+00:00 TriggerDagRunOperator 2023-05-18T06:11:21.220158+00:00 2023-05-18T06:11:21.562589+00:00 0:00:00.342431 381331 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-18T06:11:18.847499+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-18T05:00:00+00:00 EmrJobFlowSensor 2023-05-18T06:01:00.776692+00:00 2023-05-18T06:11:02.804692+00:00 0:10:02.028000 381324 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-18T06:00:58.324649+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-18T05:00:00+00:00 EmrCreateJobFlowOperator 2023-05-18T06:00:38.641455+00:00 2023-05-18T06:00:39.546354+00:00 0:00:00.904899 381322 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-18T06:00:36.296643+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-18T05:00:00+00:00 PythonOperator 2023-05-18T06:00:17.180419+00:00 2023-05-18T06:00:18.255948+00:00 0:00:01.075529 381320 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-18T06:00:14.289439+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-18T04:00:00+00:00 TriggerDagRunOperator 2023-05-18T05:13:23.697788+00:00 2023-05-18T05:13:24.133027+00:00 0:00:00.435239 381307 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-18T05:13:21.120988+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-18T04:00:00+00:00 TriggerDagRunOperator 2023-05-18T05:13:23.476828+00:00 2023-05-18T05:13:23.922760+00:00 0:00:00.445932 381306 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-18T05:13:21.121032+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-18T04:00:00+00:00 EmrJobFlowSensor 2023-05-18T05:03:14.465243+00:00 2023-05-18T05:13:16.364089+00:00 0:10:01.898846 381299 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-18T05:03:11.896742+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-18T04:00:00+00:00 EmrCreateJobFlowOperator 2023-05-18T05:02:52.023716+00:00 2023-05-18T05:02:52.895899+00:00 0:00:00.872183 381297 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-18T05:02:49.883267+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-18T04:00:00+00:00 PythonOperator 2023-05-18T05:02:32.149902+00:00 2023-05-18T05:02:33.220426+00:00 0:00:01.070524 381295 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-18T05:02:29.817043+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-18T03:00:00+00:00 TriggerDagRunOperator 2023-05-18T04:12:08.957533+00:00 2023-05-18T04:12:09.414997+00:00 0:00:00.457464 381280 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-18T04:12:06.426438+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-18T03:00:00+00:00 TriggerDagRunOperator 2023-05-18T04:12:08.856041+00:00 2023-05-18T04:12:09.236986+00:00 0:00:00.380945 381279 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-18T04:12:06.426403+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-18T03:00:00+00:00 EmrJobFlowSensor 2023-05-18T04:00:54.351652+00:00 2023-05-18T04:11:56.302052+00:00 0:11:01.950400 381272 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-18T04:00:52.022984+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-18T03:00:00+00:00 EmrCreateJobFlowOperator 2023-05-18T04:00:34.276619+00:00 2023-05-18T04:00:35.147032+00:00 0:00:00.870413 381270 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-18T04:00:32.003733+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-18T03:00:00+00:00 PythonOperator 2023-05-18T04:00:12.362111+00:00 2023-05-18T04:00:13.394328+00:00 0:00:01.032217 381268 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-18T04:00:10.005335+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-18T02:00:00+00:00 TriggerDagRunOperator 2023-05-18T03:11:15.422251+00:00 2023-05-18T03:11:15.864529+00:00 0:00:00.442278 381253 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-18T03:11:12.876330+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-18T02:00:00+00:00 TriggerDagRunOperator 2023-05-18T03:11:15.233849+00:00 2023-05-18T03:11:15.592774+00:00 0:00:00.358925 381252 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-18T03:11:12.876302+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-18T02:00:00+00:00 EmrJobFlowSensor 2023-05-18T03:00:48.394057+00:00 2023-05-18T03:10:50.399333+00:00 0:10:02.005276 381244 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-18T03:00:45.985965+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-18T02:00:00+00:00 EmrCreateJobFlowOperator 2023-05-18T03:00:26.334657+00:00 2023-05-18T03:00:27.239293+00:00 0:00:00.904636 381242 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-18T03:00:23.912521+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-18T02:00:00+00:00 PythonOperator 2023-05-18T03:00:06.708282+00:00 2023-05-18T03:00:07.852324+00:00 0:00:01.144042 381240 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-18T03:00:03.899572+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-18T01:00:00+00:00 TriggerDagRunOperator 2023-05-18T02:11:02.980552+00:00 2023-05-18T02:11:03.414534+00:00 0:00:00.433982 381227 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-18T02:11:00.515497+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-18T01:00:00+00:00 TriggerDagRunOperator 2023-05-18T02:11:02.827923+00:00 2023-05-18T02:11:03.166277+00:00 0:00:00.338354 381226 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-18T02:11:00.515462+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-18T01:00:00+00:00 EmrJobFlowSensor 2023-05-18T02:00:52.718354+00:00 2023-05-18T02:10:54.716219+00:00 0:10:01.997865 381219 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-18T02:00:50.575482+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-18T01:00:00+00:00 EmrCreateJobFlowOperator 2023-05-18T02:00:30.772521+00:00 2023-05-18T02:00:31.657278+00:00 0:00:00.884757 381217 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-18T02:00:28.543439+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-18T01:00:00+00:00 PythonOperator 2023-05-18T02:00:10.791422+00:00 2023-05-18T02:00:11.870524+00:00 0:00:01.079102 381215 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-18T02:00:08.443403+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-18T00:00:00+00:00 TriggerDagRunOperator 2023-05-18T01:11:11.710247+00:00 2023-05-18T01:11:12.164320+00:00 0:00:00.454073 381194 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-18T01:11:09.213037+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-18T00:00:00+00:00 TriggerDagRunOperator 2023-05-18T01:11:11.650495+00:00 2023-05-18T01:11:11.978271+00:00 0:00:00.327776 381193 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-18T01:11:09.212992+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-18T00:00:00+00:00 EmrJobFlowSensor 2023-05-18T01:01:06.327364+00:00 2023-05-18T01:11:08.049436+00:00 0:10:01.722072 381186 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-18T01:01:03.899557+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-18T00:00:00+00:00 EmrCreateJobFlowOperator 2023-05-18T01:00:44.453266+00:00 2023-05-18T01:00:45.351145+00:00 0:00:00.897879 381185 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-18T01:00:41.814184+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-18T00:00:00+00:00 PythonOperator 2023-05-18T01:00:24.166068+00:00 2023-05-18T01:00:25.270844+00:00 0:00:01.104776 381182 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-18T01:00:21.770685+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-17T23:00:00+00:00 TriggerDagRunOperator 2023-05-18T00:11:17.220199+00:00 2023-05-18T00:11:17.659778+00:00 0:00:00.439579 381170 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-18T00:11:14.314481+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-17T23:00:00+00:00 TriggerDagRunOperator 2023-05-18T00:11:17.039221+00:00 2023-05-18T00:11:17.386737+00:00 0:00:00.347516 381169 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-18T00:11:14.314450+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-17T23:00:00+00:00 EmrJobFlowSensor 2023-05-18T00:01:00.579562+00:00 2023-05-18T00:11:02.540426+00:00 0:10:01.960864 381162 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-18T00:00:58.002226+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-17T23:00:00+00:00 EmrCreateJobFlowOperator 2023-05-18T00:00:40.241715+00:00 2023-05-18T00:00:41.289925+00:00 0:00:01.048210 381160 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-18T00:00:37.991527+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-17T23:00:00+00:00 PythonOperator 2023-05-18T00:00:18.808072+00:00 2023-05-18T00:00:20.775772+00:00 0:00:01.967700 381158 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-18T00:00:15.910371+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-17T22:00:00+00:00 TriggerDagRunOperator 2023-05-17T23:11:10.541020+00:00 2023-05-17T23:11:10.989532+00:00 0:00:00.448512 381143 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-17T23:11:07.613537+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-17T22:00:00+00:00 TriggerDagRunOperator 2023-05-17T23:11:10.433206+00:00 2023-05-17T23:11:10.810856+00:00 0:00:00.377650 381142 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-17T23:11:07.613470+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-17T22:00:00+00:00 EmrJobFlowSensor 2023-05-17T23:00:56.680621+00:00 2023-05-17T23:10:58.588301+00:00 0:10:01.907680 381135 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-17T23:00:54.110079+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-17T22:00:00+00:00 EmrCreateJobFlowOperator 2023-05-17T23:00:34.494162+00:00 2023-05-17T23:00:35.406153+00:00 0:00:00.911991 381132 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-17T23:00:32.095300+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-17T22:00:00+00:00 PythonOperator 2023-05-17T23:00:14.456928+00:00 2023-05-17T23:00:15.550230+00:00 0:00:01.093302 381129 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-17T23:00:12.022438+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-17T21:00:00+00:00 TriggerDagRunOperator 2023-05-17T22:11:21.918898+00:00 2023-05-17T22:11:22.255342+00:00 0:00:00.336444 381113 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-17T22:11:19.114495+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-17T21:00:00+00:00 TriggerDagRunOperator 2023-05-17T22:11:21.904818+00:00 2023-05-17T22:11:22.360707+00:00 0:00:00.455889 381112 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-17T22:11:19.114448+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-17T21:00:00+00:00 EmrJobFlowSensor 2023-05-17T22:01:01.161359+00:00 2023-05-17T22:11:03.224911+00:00 0:10:02.063552 381106 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-17T22:00:58.804845+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-17T21:00:00+00:00 EmrCreateJobFlowOperator 2023-05-17T22:00:39.390406+00:00 2023-05-17T22:00:40.377385+00:00 0:00:00.986979 381104 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-17T22:00:36.811471+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-17T21:00:00+00:00 PythonOperator 2023-05-17T22:00:17.214900+00:00 2023-05-17T22:00:18.350131+00:00 0:00:01.135231 381102 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-17T22:00:14.733886+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-17T20:00:00+00:00 TriggerDagRunOperator 2023-05-17T21:11:12.669314+00:00 2023-05-17T21:11:13.142198+00:00 0:00:00.472884 381085 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-17T21:11:10.116215+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-17T20:00:00+00:00 TriggerDagRunOperator 2023-05-17T21:11:12.540528+00:00 2023-05-17T21:11:12.893274+00:00 0:00:00.352746 381084 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-17T21:11:10.116243+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-17T20:00:00+00:00 EmrJobFlowSensor 2023-05-17T21:00:51.970474+00:00 2023-05-17T21:10:53.764902+00:00 0:10:01.794428 381077 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-17T21:00:49.492006+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-17T20:00:00+00:00 EmrCreateJobFlowOperator 2023-05-17T21:00:32.310749+00:00 2023-05-17T21:00:33.569395+00:00 0:00:01.258646 381075 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-17T21:00:29.420122+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-17T20:00:00+00:00 PythonOperator 2023-05-17T21:00:09.781470+00:00 2023-05-17T21:00:11.944250+00:00 0:00:02.162780 381073 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-17T21:00:07.331315+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-17T19:00:00+00:00 TriggerDagRunOperator 2023-05-17T20:11:15.630793+00:00 2023-05-17T20:11:16.088192+00:00 0:00:00.457399 381059 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-17T20:11:12.414271+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-17T19:00:00+00:00 TriggerDagRunOperator 2023-05-17T20:11:15.415317+00:00 2023-05-17T20:11:15.779358+00:00 0:00:00.364041 381058 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-17T20:11:12.414313+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-17T19:00:00+00:00 EmrJobFlowSensor 2023-05-17T20:00:52.141873+00:00 2023-05-17T20:10:54.143432+00:00 0:10:02.001559 381052 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-17T20:00:49.592430+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-17T19:00:00+00:00 EmrCreateJobFlowOperator 2023-05-17T20:00:31.716516+00:00 2023-05-17T20:00:32.595402+00:00 0:00:00.878886 381050 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-17T20:00:29.458000+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-17T19:00:00+00:00 PythonOperator 2023-05-17T20:00:09.946514+00:00 2023-05-17T20:00:11.055716+00:00 0:00:01.109202 381047 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-17T20:00:07.439286+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-17T18:00:00+00:00 TriggerDagRunOperator 2023-05-17T19:11:16.831615+00:00 2023-05-17T19:11:17.284710+00:00 0:00:00.453095 381030 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-17T19:11:14.535228+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-17T18:00:00+00:00 TriggerDagRunOperator 2023-05-17T19:11:16.796693+00:00 2023-05-17T19:11:17.138557+00:00 0:00:00.341864 381029 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-17T19:11:14.535189+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-17T18:00:00+00:00 EmrJobFlowSensor 2023-05-17T19:00:54.163527+00:00 2023-05-17T19:10:56.256937+00:00 0:10:02.093410 381022 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-17T19:00:51.805973+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-17T18:00:00+00:00 EmrCreateJobFlowOperator 2023-05-17T19:00:33.850340+00:00 2023-05-17T19:00:34.674101+00:00 0:00:00.823761 381021 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-17T19:00:31.725687+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-17T18:00:00+00:00 PythonOperator 2023-05-17T19:00:11.840039+00:00 2023-05-17T19:00:12.907946+00:00 0:00:01.067907 381020 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-17T19:00:09.705921+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-17T17:00:00+00:00 TriggerDagRunOperator 2023-05-17T18:11:19.225099+00:00 2023-05-17T18:11:19.683219+00:00 0:00:00.458120 381002 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-17T18:11:16.674486+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-17T17:00:00+00:00 TriggerDagRunOperator 2023-05-17T18:11:19.042021+00:00 2023-05-17T18:11:19.410837+00:00 0:00:00.368816 381001 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-17T18:11:16.674533+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-17T17:00:00+00:00 EmrJobFlowSensor 2023-05-17T18:01:00.307613+00:00 2023-05-17T18:11:02.403534+00:00 0:10:02.095921 380994 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-17T18:00:57.636724+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-17T17:00:00+00:00 EmrCreateJobFlowOperator 2023-05-17T18:00:37.761441+00:00 2023-05-17T18:00:38.617029+00:00 0:00:00.855588 380993 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-17T18:00:35.584495+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-17T17:00:00+00:00 PythonOperator 2023-05-17T18:00:15.995334+00:00 2023-05-17T18:00:17.876049+00:00 0:00:01.880715 380991 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-17T18:00:13.495316+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-17T16:00:00+00:00 TriggerDagRunOperator 2023-05-17T17:11:33.714142+00:00 2023-05-17T17:11:34.185098+00:00 0:00:00.470956 380976 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-17T17:11:31.333256+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-17T16:00:00+00:00 TriggerDagRunOperator 2023-05-17T17:11:33.582606+00:00 2023-05-17T17:11:34.017870+00:00 0:00:00.435264 380975 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-17T17:11:31.333284+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-17T16:00:00+00:00 EmrJobFlowSensor 2023-05-17T17:01:11.887064+00:00 2023-05-17T17:11:13.646814+00:00 0:10:01.759750 380966 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-17T17:01:09.716901+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-17T16:00:00+00:00 EmrCreateJobFlowOperator 2023-05-17T17:00:49.802013+00:00 2023-05-17T17:00:50.636293+00:00 0:00:00.834280 380965 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-17T17:00:47.661695+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-17T16:00:00+00:00 PythonOperator 2023-05-17T17:00:29.886014+00:00 2023-05-17T17:00:31.103178+00:00 0:00:01.217164 380964 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-17T17:00:27.643796+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-17T15:00:00+00:00 TriggerDagRunOperator 2023-05-17T16:16:00.750086+00:00 2023-05-17T16:16:01.203612+00:00 0:00:00.453526 380951 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-17T16:15:57.974293+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-17T15:00:00+00:00 TriggerDagRunOperator 2023-05-17T16:16:00.658330+00:00 2023-05-17T16:16:01.002712+00:00 0:00:00.344382 380950 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-17T16:15:57.974264+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-17T15:00:00+00:00 EmrJobFlowSensor 2023-05-17T16:01:27.397590+00:00 2023-05-17T16:10:29.075222+00:00 0:09:01.677632 380942 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-17T16:01:24.731556+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-17T15:00:00+00:00 EmrCreateJobFlowOperator 2023-05-17T16:00:28.770692+00:00 2023-05-17T16:00:29.599633+00:00 0:00:00.828941 380940 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-17T16:00:26.484517+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-17T15:00:00+00:00 PythonOperator 2023-05-17T16:00:08.799490+00:00 2023-05-17T16:00:09.959433+00:00 0:00:01.159943 380938 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-17T16:00:06.441594+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-17T14:00:00+00:00 TriggerDagRunOperator 2023-05-17T15:19:50.018060+00:00 2023-05-17T15:19:50.464487+00:00 0:00:00.446427 380928 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-17T15:19:47.509771+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-17T14:00:00+00:00 TriggerDagRunOperator 2023-05-17T15:19:49.931706+00:00 2023-05-17T15:19:50.296998+00:00 0:00:00.365292 380927 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-17T15:19:47.509742+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-17T14:00:00+00:00 EmrJobFlowSensor 2023-05-17T15:01:35.052939+00:00 2023-05-17T15:11:36.869565+00:00 0:10:01.816626 380921 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-17T15:01:32.732042+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-17T14:00:00+00:00 EmrCreateJobFlowOperator 2023-05-17T15:01:13.066763+00:00 2023-05-17T15:01:14.005196+00:00 0:00:00.938433 380919 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-17T15:01:10.709362+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-17T14:00:00+00:00 PythonOperator 2023-05-17T15:00:53.269876+00:00 2023-05-17T15:00:54.441511+00:00 0:00:01.171635 380917 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-17T15:00:50.685720+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-17T13:00:00+00:00 TriggerDagRunOperator 2023-05-17T14:18:56.006246+00:00 2023-05-17T14:18:56.490469+00:00 0:00:00.484223 380905 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-17T14:18:53.339164+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-17T13:00:00+00:00 TriggerDagRunOperator 2023-05-17T14:18:55.907094+00:00 2023-05-17T14:18:56.282123+00:00 0:00:00.375029 380904 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-17T14:18:53.339192+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-17T13:00:00+00:00 EmrJobFlowSensor 2023-05-17T14:00:57.128251+00:00 2023-05-17T14:10:58.899472+00:00 0:10:01.771221 380897 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-17T14:00:54.528202+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-17T13:00:00+00:00 EmrCreateJobFlowOperator 2023-05-17T14:00:37.622648+00:00 2023-05-17T14:00:38.613141+00:00 0:00:00.990493 380895 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-17T14:00:34.483880+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-17T13:00:00+00:00 PythonOperator 2023-05-17T14:00:14.649470+00:00 2023-05-17T14:00:15.719829+00:00 0:00:01.070359 380893 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-17T14:00:12.325147+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-17T12:00:00+00:00 TriggerDagRunOperator 2023-05-17T13:30:07.899147+00:00 2023-05-17T13:30:08.354701+00:00 0:00:00.455554 380882 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-17T13:30:05.398295+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-17T12:00:00+00:00 TriggerDagRunOperator 2023-05-17T13:30:07.713390+00:00 2023-05-17T13:30:08.053991+00:00 0:00:00.340601 380881 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-17T13:30:05.398265+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-17T12:00:00+00:00 EmrJobFlowSensor 2023-05-17T13:05:45.265148+00:00 2023-05-17T13:15:47.096976+00:00 0:10:01.831828 380877 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-17T13:05:42.814568+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-17T12:00:00+00:00 EmrCreateJobFlowOperator 2023-05-17T13:05:25.041234+00:00 2023-05-17T13:05:26.026425+00:00 0:00:00.985191 380875 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-17T13:05:22.747213+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-17T12:00:00+00:00 PythonOperator 2023-05-17T13:05:03.690010+00:00 2023-05-17T13:05:05.741587+00:00 0:00:02.051577 380871 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-17T13:05:00.727636+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-17T11:00:00+00:00 TriggerDagRunOperator 2023-05-17T12:12:25.870290+00:00 2023-05-17T12:12:26.322014+00:00 0:00:00.451724 380857 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-17T12:12:22.905499+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-17T11:00:00+00:00 TriggerDagRunOperator 2023-05-17T12:12:25.790463+00:00 2023-05-17T12:12:26.131561+00:00 0:00:00.341098 380856 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-17T12:12:22.905542+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-17T11:00:00+00:00 EmrJobFlowSensor 2023-05-17T12:02:16.543577+00:00 2023-05-17T12:12:18.443850+00:00 0:10:01.900273 380849 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-17T12:02:14.212849+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-17T11:00:00+00:00 EmrCreateJobFlowOperator 2023-05-17T12:01:56.583931+00:00 2023-05-17T12:01:57.540911+00:00 0:00:00.956980 380847 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-17T12:01:54.203856+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-17T11:00:00+00:00 PythonOperator 2023-05-17T12:01:34.914775+00:00 2023-05-17T12:01:35.990552+00:00 0:00:01.075777 380845 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-17T12:01:32.131114+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-17T10:00:00+00:00 TriggerDagRunOperator 2023-05-17T11:17:38.409002+00:00 2023-05-17T11:17:38.920472+00:00 0:00:00.511470 380834 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-17T11:17:35.926855+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-17T10:00:00+00:00 TriggerDagRunOperator 2023-05-17T11:17:38.359024+00:00 2023-05-17T11:17:38.751329+00:00 0:00:00.392305 380833 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-17T11:17:35.926884+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-17T10:00:00+00:00 EmrJobFlowSensor 2023-05-17T11:07:26.537905+00:00 2023-05-17T11:17:28.344074+00:00 0:10:01.806169 380828 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-17T11:07:24.330871+00:00 2 default_pool