Task Instances


  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 exchange-dsp-reporting_v002 create_emr_steps 01-12T04:00:00+00:00 PythonOperator 01-13T04:00:15.263286+00:00 01-13T04:00:16.336271+00:00 0:00:01.072985 470031 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 01-13T04:00:13.068686+00:00 2 default_pool
success exchange-dsp-reporting_v002 check_cluster_status 01-11T04:00:00+00:00 EmrJobFlowSensor 01-12T04:00:54.137205+00:00 01-12T04:11:56.018847+00:00 0:11:01.881642 469576 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 01-12T04:00:51.972377+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_cluster_and_add_emr_steps 01-11T04:00:00+00:00 EmrCreateJobFlowOperator 01-12T04:00:34.050180+00:00 01-12T04:00:34.884579+00:00 0:00:00.834399 469573 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 01-12T04:00:31.892374+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_emr_steps 01-11T04:00:00+00:00 PythonOperator 01-12T04:00:12.261017+00:00 01-12T04:00:13.258341+00:00 0:00:00.997324 469569 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 01-12T04:00:09.878535+00:00 2 default_pool
success exchange-dsp-reporting_v002 check_cluster_status 01-10T04:00:00+00:00 EmrJobFlowSensor 01-11T04:01:37.995045+00:00 01-11T04:10:39.618678+00:00 0:09:01.623633 469099 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 01-11T04:01:35.958857+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_cluster_and_add_emr_steps 01-10T04:00:00+00:00 EmrCreateJobFlowOperator 01-11T04:00:41.431422+00:00 01-11T04:00:42.423341+00:00 0:00:00.991919 469096 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 01-11T04:00:39.315081+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_emr_steps 01-10T04:00:00+00:00 PythonOperator 01-11T04:00:17.429785+00:00 01-11T04:00:18.428476+00:00 0:00:00.998691 469094 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 01-11T04:00:15.297436+00:00 2 default_pool
success exchange-dsp-reporting_v002 check_cluster_status 01-09T04:00:00+00:00 EmrJobFlowSensor 01-10T04:01:01.603831+00:00 01-10T04:11:03.437633+00:00 0:10:01.833802 468680 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 01-10T04:00:59.859295+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_cluster_and_add_emr_steps 01-09T04:00:00+00:00 EmrCreateJobFlowOperator 01-10T04:00:39.960753+00:00 01-10T04:00:41.349900+00:00 0:00:01.389147 468677 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 01-10T04:00:37.793424+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_emr_steps 01-09T04:00:00+00:00 PythonOperator 01-10T04:00:20.222741+00:00 01-10T04:00:21.226035+00:00 0:00:01.003294 468674 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 01-10T04:00:17.785427+00:00 2 default_pool
success exchange-dsp-reporting_v002 check_cluster_status 01-08T04:00:00+00:00 EmrJobFlowSensor 01-09T04:01:04.527599+00:00 01-09T04:11:06.308633+00:00 0:10:01.781034 468241 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 01-09T04:01:02.447264+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_cluster_and_add_emr_steps 01-08T04:00:00+00:00 EmrCreateJobFlowOperator 01-09T04:00:42.628603+00:00 01-09T04:00:43.386728+00:00 0:00:00.758125 468238 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 01-09T04:00:40.485154+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_emr_steps 01-08T04:00:00+00:00 PythonOperator 01-09T04:00:22.605630+00:00 01-09T04:00:23.620692+00:00 0:00:01.015062 468235 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 01-09T04:00:20.466494+00:00 2 default_pool
success exchange-dsp-reporting_v002 check_cluster_status 01-07T04:00:00+00:00 EmrJobFlowSensor 01-08T04:01:16.355006+00:00 01-08T04:11:18.602802+00:00 0:10:02.247796 467802 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 01-08T04:01:13.649591+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_cluster_and_add_emr_steps 01-07T04:00:00+00:00 EmrCreateJobFlowOperator 01-08T04:00:53.286197+00:00 01-08T04:00:54.047330+00:00 0:00:00.761133 467799 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 01-08T04:00:51.631297+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_emr_steps 01-07T04:00:00+00:00 PythonOperator 01-08T04:00:34.717620+00:00 01-08T04:00:35.680336+00:00 0:00:00.962716 467796 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 01-08T04:00:31.615300+00:00 2 default_pool
success exchange-dsp-reporting_v002 check_cluster_status 01-06T04:00:00+00:00 EmrJobFlowSensor 01-07T04:01:07.298788+00:00 01-07T04:11:09.059722+00:00 0:10:01.760934 467361 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 01-07T04:01:05.699737+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_cluster_and_add_emr_steps 01-06T04:00:00+00:00 EmrCreateJobFlowOperator 01-07T04:00:45.532880+00:00 01-07T04:00:46.328558+00:00 0:00:00.795678 467358 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 01-07T04:00:43.688608+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_emr_steps 01-06T04:00:00+00:00 PythonOperator 01-07T04:00:23.408876+00:00 01-07T04:00:24.663996+00:00 0:00:01.255120 467355 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 01-07T04:00:21.667530+00:00 2 default_pool
success exchange-dsp-reporting_v002 check_cluster_status 01-05T04:00:00+00:00 EmrJobFlowSensor 01-06T04:01:43.505132+00:00 01-06T04:11:45.205905+00:00 0:10:01.700773 466922 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 01-06T04:01:41.870151+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_cluster_and_add_emr_steps 01-05T04:00:00+00:00 EmrCreateJobFlowOperator 01-06T04:01:23.409679+00:00 01-06T04:01:24.410324+00:00 0:00:01.000645 466919 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 01-06T04:01:21.794416+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_emr_steps 01-05T04:00:00+00:00 PythonOperator 01-06T04:01:01.399205+00:00 01-06T04:01:02.371590+00:00 0:00:00.972385 466916 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 01-06T04:00:59.778277+00:00 2 default_pool
success exchange-dsp-reporting_v002 check_cluster_status 01-04T04:00:00+00:00 EmrJobFlowSensor 01-05T04:00:49.397616+00:00 01-05T04:10:51.170302+00:00 0:10:01.772686 466489 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 01-05T04:00:47.769193+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_cluster_and_add_emr_steps 01-04T04:00:00+00:00 EmrCreateJobFlowOperator 01-05T04:00:28.713286+00:00 01-05T04:00:29.426808+00:00 0:00:00.713522 466486 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 01-05T04:00:25.782397+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_emr_steps 01-04T04:00:00+00:00 PythonOperator 01-05T04:00:05.827547+00:00 01-05T04:00:06.780722+00:00 0:00:00.953175 466483 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 01-05T04:00:03.779793+00:00 2 default_pool
success exchange-dsp-reporting_v002 check_cluster_status 01-03T04:00:00+00:00 EmrJobFlowSensor 01-04T04:01:02.637496+00:00 01-04T04:11:04.417398+00:00 0:10:01.779902 466050 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 01-04T04:01:00.377084+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_cluster_and_add_emr_steps 01-03T04:00:00+00:00 EmrCreateJobFlowOperator 01-04T04:00:43.147618+00:00 01-04T04:00:44.026141+00:00 0:00:00.878523 466047 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 01-04T04:00:40.363160+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_emr_steps 01-03T04:00:00+00:00 PythonOperator 01-04T04:00:21.303373+00:00 01-04T04:00:22.263849+00:00 0:00:00.960476 466044 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 01-04T04:00:18.281362+00:00 2 default_pool
success exchange-dsp-reporting_v002 check_cluster_status 01-02T04:00:00+00:00 EmrJobFlowSensor 01-03T04:00:49.369061+00:00 01-03T04:10:51.067691+00:00 0:10:01.698630 465614 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 01-03T04:00:47.366610+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_cluster_and_add_emr_steps 01-02T04:00:00+00:00 EmrCreateJobFlowOperator 01-03T04:00:27.010540+00:00 01-03T04:00:27.812550+00:00 0:00:00.802010 465611 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 01-03T04:00:25.344983+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_emr_steps 01-02T04:00:00+00:00 PythonOperator 01-03T04:00:07.446163+00:00 01-03T04:00:08.378586+00:00 0:00:00.932423 465608 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 01-03T04:00:05.327438+00:00 2 default_pool
success exchange-dsp-reporting_v002 check_cluster_status 01-01T04:00:00+00:00 EmrJobFlowSensor 01-02T04:00:52.864656+00:00 01-02T04:10:54.669589+00:00 0:10:01.804933 465187 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 01-02T04:00:50.728670+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_cluster_and_add_emr_steps 01-01T04:00:00+00:00 EmrCreateJobFlowOperator 01-02T04:00:30.949565+00:00 01-02T04:00:31.712755+00:00 0:00:00.763190 465184 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 01-02T04:00:28.764760+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_emr_steps 01-01T04:00:00+00:00 PythonOperator 01-02T04:00:08.697629+00:00 01-02T04:00:09.698788+00:00 0:00:01.001159 465181 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 01-02T04:00:06.696615+00:00 2 default_pool
success exchange-dsp-reporting_v002 check_cluster_status 2023-12-31T04:00:00+00:00 EmrJobFlowSensor 01-01T04:00:50.203476+00:00 01-01T04:11:52.098423+00:00 0:11:01.894947 464761 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 01-01T04:00:48.476573+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_cluster_and_add_emr_steps 2023-12-31T04:00:00+00:00 EmrCreateJobFlowOperator 01-01T04:00:28.502671+00:00 01-01T04:00:29.303975+00:00 0:00:00.801304 464758 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 01-01T04:00:26.463350+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_emr_steps 2023-12-31T04:00:00+00:00 PythonOperator 01-01T04:00:08.204178+00:00 01-01T04:00:09.178886+00:00 0:00:00.974708 464755 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 01-01T04:00:06.394207+00:00 2 default_pool
success exchange-dsp-reporting_v002 check_cluster_status 2023-12-30T04:00:00+00:00 EmrJobFlowSensor 2023-12-31T04:00:47.708330+00:00 2023-12-31T04:10:49.436591+00:00 0:10:01.728261 464342 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-31T04:00:45.882424+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_cluster_and_add_emr_steps 2023-12-30T04:00:00+00:00 EmrCreateJobFlowOperator 2023-12-31T04:00:27.613371+00:00 2023-12-31T04:00:28.403097+00:00 0:00:00.789726 464339 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-31T04:00:25.871031+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_emr_steps 2023-12-30T04:00:00+00:00 PythonOperator 2023-12-31T04:00:07.208857+00:00 2023-12-31T04:00:08.920846+00:00 0:00:01.711989 464336 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-31T04:00:03.852381+00:00 2 default_pool
success exchange-dsp-reporting_v002 check_cluster_status 2023-12-29T04:00:00+00:00 EmrJobFlowSensor 2023-12-30T04:01:31.942544+00:00 2023-12-30T04:11:33.729211+00:00 0:10:01.786667 463914 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-30T04:01:29.883952+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_cluster_and_add_emr_steps 2023-12-29T04:00:00+00:00 EmrCreateJobFlowOperator 2023-12-30T04:00:26.832603+00:00 2023-12-30T04:00:27.675134+00:00 0:00:00.842531 463909 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-30T04:00:24.375381+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_emr_steps 2023-12-29T04:00:00+00:00 PythonOperator 2023-12-30T04:00:06.629062+00:00 2023-12-30T04:00:07.550512+00:00 0:00:00.921450 463906 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-30T04:00:04.360056+00:00 2 default_pool
success exchange-dsp-reporting_v002 check_cluster_status 2023-12-28T04:00:00+00:00 EmrJobFlowSensor 2023-12-29T04:01:38.999794+00:00 2023-12-29T04:11:40.725189+00:00 0:10:01.725395 463491 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-29T04:01:37.306360+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_cluster_and_add_emr_steps 2023-12-28T04:00:00+00:00 EmrCreateJobFlowOperator 2023-12-29T04:01:18.898439+00:00 2023-12-29T04:01:19.713359+00:00 0:00:00.814920 463488 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-29T04:01:17.289427+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_emr_steps 2023-12-28T04:00:00+00:00 PythonOperator 2023-12-29T04:00:12.654231+00:00 2023-12-29T04:00:13.637276+00:00 0:00:00.983045 463483 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-29T04:00:10.972113+00:00 2 default_pool
success exchange-dsp-reporting_v002 check_cluster_status 2023-12-27T04:00:00+00:00 EmrJobFlowSensor 2023-12-28T04:14:21.710629+00:00 2023-12-28T04:14:22.179887+00:00 0:00:00.469258 463062 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-28T04:14:20.005250+00:00 3 default_pool
success exchange-dsp-reporting_v002 create_cluster_and_add_emr_steps 2023-12-27T04:00:00+00:00 EmrCreateJobFlowOperator 2023-12-28T04:00:39.790922+00:00 2023-12-28T04:00:40.586373+00:00 0:00:00.795451 463052 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-28T04:00:38.087472+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_emr_steps 2023-12-27T04:00:00+00:00 PythonOperator 2023-12-28T04:00:19.805740+00:00 2023-12-28T04:00:20.768910+00:00 0:00:00.963170 463049 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-28T04:00:18.059311+00:00 2 default_pool
success exchange-dsp-reporting_v002 check_cluster_status 2023-12-26T04:00:00+00:00 EmrJobFlowSensor 2023-12-27T04:00:48.565129+00:00 2023-12-27T04:11:50.360483+00:00 0:11:01.795354 462608 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-27T04:00:46.364165+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_cluster_and_add_emr_steps 2023-12-26T04:00:00+00:00 EmrCreateJobFlowOperator 2023-12-27T04:00:26.562120+00:00 2023-12-27T04:00:27.401441+00:00 0:00:00.839321 462605 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-27T04:00:24.377700+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_emr_steps 2023-12-26T04:00:00+00:00 PythonOperator 2023-12-27T04:00:06.413992+00:00 2023-12-27T04:00:07.356705+00:00 0:00:00.942713 462602 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-27T04:00:04.363048+00:00 2 default_pool
success exchange-dsp-reporting_v002 check_cluster_status 2023-12-25T04:00:00+00:00 EmrJobFlowSensor 2023-12-26T04:02:00.255633+00:00 2023-12-26T04:11:02.068110+00:00 0:09:01.812477 462176 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-26T04:01:58.230175+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_cluster_and_add_emr_steps 2023-12-25T04:00:00+00:00 EmrCreateJobFlowOperator 2023-12-26T04:00:37.292931+00:00 2023-12-26T04:00:38.289215+00:00 0:00:00.996284 462171 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-26T04:00:35.642972+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_emr_steps 2023-12-25T04:00:00+00:00 PythonOperator 2023-12-26T04:00:17.999293+00:00 2023-12-26T04:00:18.906738+00:00 0:00:00.907445 462169 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-26T04:00:15.626443+00:00 2 default_pool
success exchange-dsp-reporting_v002 check_cluster_status 2023-12-24T04:00:00+00:00 EmrJobFlowSensor 2023-12-25T04:06:18.361010+00:00 2023-12-25T04:17:20.541470+00:00 0:11:02.180460 461746 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-25T04:06:16.291169+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_cluster_and_add_emr_steps 2023-12-24T04:00:00+00:00 EmrCreateJobFlowOperator 2023-12-25T04:05:56.135236+00:00 2023-12-25T04:05:56.971180+00:00 0:00:00.835944 461741 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-25T04:05:54.239669+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_emr_steps 2023-12-24T04:00:00+00:00 PythonOperator 2023-12-25T04:05:36.242336+00:00 2023-12-25T04:05:37.134555+00:00 0:00:00.892219 461738 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-25T04:05:34.223692+00:00 2 default_pool
success exchange-dsp-reporting_v002 check_cluster_status 2023-12-23T04:00:00+00:00 EmrJobFlowSensor 2023-12-24T04:00:52.089024+00:00 2023-12-24T04:10:53.806021+00:00 0:10:01.716997 461306 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-24T04:00:50.464528+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_cluster_and_add_emr_steps 2023-12-23T04:00:00+00:00 EmrCreateJobFlowOperator 2023-12-24T04:00:30.626263+00:00 2023-12-24T04:00:31.454209+00:00 0:00:00.827946 461303 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-24T04:00:28.469851+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_emr_steps 2023-12-23T04:00:00+00:00 PythonOperator 2023-12-24T04:00:10.925887+00:00 2023-12-24T04:00:11.894914+00:00 0:00:00.969027 461300 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-24T04:00:08.485195+00:00 2 default_pool
success exchange-dsp-reporting_v002 check_cluster_status 2023-12-22T04:00:00+00:00 EmrJobFlowSensor 2023-12-23T04:01:07.190791+00:00 2023-12-23T04:11:08.974907+00:00 0:10:01.784116 460891 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-23T04:01:05.569713+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_cluster_and_add_emr_steps 2023-12-22T04:00:00+00:00 EmrCreateJobFlowOperator 2023-12-23T04:00:45.229454+00:00 2023-12-23T04:00:46.108401+00:00 0:00:00.878947 460888 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-23T04:00:43.549648+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_emr_steps 2023-12-22T04:00:00+00:00 PythonOperator 2023-12-23T04:00:23.768982+00:00 2023-12-23T04:00:24.669133+00:00 0:00:00.900151 460885 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-23T04:00:21.585999+00:00 2 default_pool
success exchange-dsp-reporting_v002 check_cluster_status 2023-12-21T04:00:00+00:00 EmrJobFlowSensor 2023-12-22T04:01:14.007132+00:00 2023-12-22T04:11:15.684345+00:00 0:10:01.677213 460469 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-22T04:01:12.385452+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_cluster_and_add_emr_steps 2023-12-21T04:00:00+00:00 EmrCreateJobFlowOperator 2023-12-22T04:00:52.954426+00:00 2023-12-22T04:00:53.695948+00:00 0:00:00.741522 460466 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-22T04:00:50.345840+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_emr_steps 2023-12-21T04:00:00+00:00 PythonOperator 2023-12-22T04:00:31.906734+00:00 2023-12-22T04:00:32.821326+00:00 0:00:00.914592 460463 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-22T04:00:30.323022+00:00 2 default_pool
success exchange-dsp-reporting_v002 check_cluster_status 2023-12-20T04:00:00+00:00 EmrJobFlowSensor 2023-12-21T04:01:07.521976+00:00 2023-12-21T04:11:09.213155+00:00 0:10:01.691179 460027 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-21T04:01:05.086215+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_cluster_and_add_emr_steps 2023-12-20T04:00:00+00:00 EmrCreateJobFlowOperator 2023-12-21T04:00:45.272274+00:00 2023-12-21T04:00:46.108238+00:00 0:00:00.835964 460024 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-21T04:00:43.077877+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_emr_steps 2023-12-20T04:00:00+00:00 PythonOperator 2023-12-21T04:00:25.446316+00:00 2023-12-21T04:00:26.314279+00:00 0:00:00.867963 460021 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-21T04:00:23.019182+00:00 2 default_pool
success exchange-dsp-reporting_v002 check_cluster_status 2023-12-19T04:00:00+00:00 EmrJobFlowSensor 2023-12-20T04:00:56.476588+00:00 2023-12-20T04:10:58.508593+00:00 0:10:02.032005 459588 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-20T04:00:54.407915+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_cluster_and_add_emr_steps 2023-12-19T04:00:00+00:00 EmrCreateJobFlowOperator 2023-12-20T04:00:34.155150+00:00 2023-12-20T04:00:34.974487+00:00 0:00:00.819337 459585 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-20T04:00:32.391491+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_emr_steps 2023-12-19T04:00:00+00:00 PythonOperator 2023-12-20T04:00:14.046222+00:00 2023-12-20T04:00:14.941358+00:00 0:00:00.895136 459582 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-20T04:00:12.347182+00:00 2 default_pool
success exchange-dsp-reporting_v002 check_cluster_status 2023-12-18T04:00:00+00:00 EmrJobFlowSensor 2023-12-19T04:01:00.413540+00:00 2023-12-19T04:12:02.384541+00:00 0:11:01.971001 459160 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-19T04:00:58.754372+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_cluster_and_add_emr_steps 2023-12-18T04:00:00+00:00 EmrCreateJobFlowOperator 2023-12-19T04:00:39.201093+00:00 2023-12-19T04:00:39.957942+00:00 0:00:00.756849 459157 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-19T04:00:36.687122+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_emr_steps 2023-12-18T04:00:00+00:00 PythonOperator 2023-12-19T04:00:18.315332+00:00 2023-12-19T04:00:19.199649+00:00 0:00:00.884317 459154 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-19T04:00:16.685143+00:00 2 default_pool
success exchange-dsp-reporting_v002 check_cluster_status 2023-12-17T04:00:00+00:00 EmrJobFlowSensor 2023-12-18T04:01:27.303566+00:00 2023-12-18T04:12:29.361577+00:00 0:11:02.058011 458723 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-18T04:01:25.708447+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_cluster_and_add_emr_steps 2023-12-17T04:00:00+00:00 EmrCreateJobFlowOperator 2023-12-18T04:01:07.651489+00:00 2023-12-18T04:01:08.444739+00:00 0:00:00.793250 458720 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-18T04:01:05.693154+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_emr_steps 2023-12-17T04:00:00+00:00 PythonOperator 2023-12-18T04:00:45.357841+00:00 2023-12-18T04:00:46.308176+00:00 0:00:00.950335 458717 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-18T04:00:43.672745+00:00 2 default_pool
success exchange-dsp-reporting_v002 check_cluster_status 2023-12-16T04:00:00+00:00 EmrJobFlowSensor 2023-12-17T04:00:53.976560+00:00 2023-12-17T04:11:56.115410+00:00 0:11:02.138850 458295 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-17T04:00:51.464227+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_cluster_and_add_emr_steps 2023-12-16T04:00:00+00:00 EmrCreateJobFlowOperator 2023-12-17T04:00:33.737897+00:00 2023-12-17T04:00:34.493153+00:00 0:00:00.755256 458292 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-17T04:00:31.397323+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_emr_steps 2023-12-16T04:00:00+00:00 PythonOperator 2023-12-17T04:00:11.085055+00:00 2023-12-17T04:00:12.024757+00:00 0:00:00.939702 458289 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-17T04:00:09.363080+00:00 2 default_pool
success exchange-dsp-reporting_v002 check_cluster_status 2023-12-15T04:00:00+00:00 EmrJobFlowSensor 2023-12-16T04:00:49.640257+00:00 2023-12-16T04:10:51.447851+00:00 0:10:01.807594 457869 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-16T04:00:47.619660+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_cluster_and_add_emr_steps 2023-12-15T04:00:00+00:00 EmrCreateJobFlowOperator 2023-12-16T04:00:27.759952+00:00 2023-12-16T04:00:28.537783+00:00 0:00:00.777831 457866 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-16T04:00:25.601473+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_emr_steps 2023-12-15T04:00:00+00:00 PythonOperator 2023-12-16T04:00:08.266310+00:00 2023-12-16T04:00:09.150457+00:00 0:00:00.884147 457863 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-16T04:00:05.664545+00:00 2 default_pool
success exchange-dsp-reporting_v002 check_cluster_status 2023-12-14T04:00:00+00:00 EmrJobFlowSensor 2023-12-15T04:01:04.445427+00:00 2023-12-15T04:11:06.190800+00:00 0:10:01.745373 457435 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-15T04:01:02.368774+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_cluster_and_add_emr_steps 2023-12-14T04:00:00+00:00 EmrCreateJobFlowOperator 2023-12-15T04:00:43.030516+00:00 2023-12-15T04:00:43.738406+00:00 0:00:00.707890 457432 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-15T04:00:40.354439+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_emr_steps 2023-12-14T04:00:00+00:00 PythonOperator 2023-12-15T04:00:21.828689+00:00 2023-12-15T04:00:22.695514+00:00 0:00:00.866825 457429 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-15T04:00:18.386015+00:00 2 default_pool
success exchange-dsp-reporting_v002 check_cluster_status 2023-12-13T04:00:00+00:00 EmrJobFlowSensor 2023-12-14T04:01:00.855090+00:00 2023-12-14T04:12:02.935320+00:00 0:11:02.080230 456950 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-14T04:00:59.233734+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_cluster_and_add_emr_steps 2023-12-13T04:00:00+00:00 EmrCreateJobFlowOperator 2023-12-14T04:00:41.243200+00:00 2023-12-14T04:00:42.114572+00:00 0:00:00.871372 456947 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-14T04:00:39.221139+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_emr_steps 2023-12-13T04:00:00+00:00 PythonOperator 2023-12-14T04:00:19.351873+00:00 2023-12-14T04:00:20.172773+00:00 0:00:00.820900 456944 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-14T04:00:17.199869+00:00 2 default_pool
success exchange-dsp-reporting_v002 check_cluster_status 2023-12-12T04:00:00+00:00 EmrJobFlowSensor 2023-12-13T04:01:20.207460+00:00 2023-12-13T04:11:22.012228+00:00 0:10:01.804768 456398 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-13T04:01:18.342483+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_cluster_and_add_emr_steps 2023-12-12T04:00:00+00:00 EmrCreateJobFlowOperator 2023-12-13T04:00:43.425932+00:00 2023-12-13T04:00:44.173881+00:00 0:00:00.747949 456396 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-13T04:00:41.279486+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_emr_steps 2023-12-12T04:00:00+00:00 PythonOperator 2023-12-13T04:00:22.890615+00:00 2023-12-13T04:00:23.734491+00:00 0:00:00.843876 456393 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-13T04:00:21.263841+00:00 2 default_pool
success exchange-dsp-reporting_v002 check_cluster_status 2023-12-11T04:00:00+00:00 EmrJobFlowSensor 2023-12-12T04:00:51.205522+00:00 2023-12-12T04:11:53.076988+00:00 0:11:01.871466 455861 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-12T04:00:49.471312+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_cluster_and_add_emr_steps 2023-12-11T04:00:00+00:00 EmrCreateJobFlowOperator 2023-12-12T04:00:31.185549+00:00 2023-12-12T04:00:32.040920+00:00 0:00:00.855371 455858 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-12T04:00:29.458309+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_emr_steps 2023-12-11T04:00:00+00:00 PythonOperator 2023-12-12T04:00:09.514962+00:00 2023-12-12T04:00:10.327055+00:00 0:00:00.812093 455855 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-12T04:00:07.385566+00:00 2 default_pool
success exchange-dsp-reporting_v002 check_cluster_status 2023-12-10T04:00:00+00:00 EmrJobFlowSensor 2023-12-11T04:00:47.007961+00:00 2023-12-11T04:10:48.927316+00:00 0:10:01.919355 455323 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-11T04:00:45.381827+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_cluster_and_add_emr_steps 2023-12-10T04:00:00+00:00 EmrCreateJobFlowOperator 2023-12-11T04:00:27.006032+00:00 2023-12-11T04:00:27.888042+00:00 0:00:00.882010 455320 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-11T04:00:25.361395+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_emr_steps 2023-12-10T04:00:00+00:00 PythonOperator 2023-12-11T04:00:05.466503+00:00 2023-12-11T04:00:06.373585+00:00 0:00:00.907082 455317 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-11T04:00:03.383173+00:00 2 default_pool