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 exchange-dsp-reporting_v002 check_cluster_status 11-20T04:00:00+00:00 EmrJobFlowSensor 11-21T04:00:53.548129+00:00 11-21T04:08:55.450439+00:00 0:08:01.902310 639767 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 11-21T04:00:50.218368+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_cluster_and_add_emr_steps 11-20T04:00:00+00:00 EmrCreateJobFlowOperator 11-21T04:00:31.831243+00:00 11-21T04:00:32.863708+00:00 0:00:01.032465 639763 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 11-21T04:00:28.264218+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_emr_steps 11-20T04:00:00+00:00 PythonOperator 11-21T04:00:09.303623+00:00 11-21T04:00:11.838411+00:00 0:00:02.534788 639758 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 11-21T04:00:04.269213+00:00 2 default_pool
success exchange-dsp-reporting_v002 check_cluster_status 11-19T04:00:00+00:00 EmrJobFlowSensor 11-20T04:01:01.759477+00:00 11-20T04:10:03.884614+00:00 0:09:02.125137 639209 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 11-20T04:00:58.151383+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_cluster_and_add_emr_steps 11-19T04:00:00+00:00 EmrCreateJobFlowOperator 11-20T04:00:39.511078+00:00 11-20T04:00:40.610334+00:00 0:00:01.099256 639205 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 11-20T04:00:36.003966+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_emr_steps 11-19T04:00:00+00:00 PythonOperator 11-20T04:00:15.376813+00:00 11-20T04:00:16.715961+00:00 0:00:01.339148 639201 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 11-20T04:00:11.958295+00:00 2 default_pool
success exchange-dsp-reporting_v002 check_cluster_status 11-18T04:00:00+00:00 EmrJobFlowSensor 11-19T04:01:03.957191+00:00 11-19T04:10:06.090020+00:00 0:09:02.132829 638641 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 11-19T04:01:00.364113+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_cluster_and_add_emr_steps 11-18T04:00:00+00:00 EmrCreateJobFlowOperator 11-19T04:00:44.524820+00:00 11-19T04:00:45.750101+00:00 0:00:01.225281 638637 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 11-19T04:00:40.257217+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_emr_steps 11-18T04:00:00+00:00 PythonOperator 11-19T04:00:17.757961+00:00 11-19T04:00:19.388562+00:00 0:00:01.630601 638632 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 11-19T04:00:14.291301+00:00 2 default_pool
success exchange-dsp-reporting_v002 check_cluster_status 11-17T04:00:00+00:00 EmrJobFlowSensor 11-18T04:01:05.341528+00:00 11-18T04:10:07.424042+00:00 0:09:02.082514 638059 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 11-18T04:01:00.117051+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_cluster_and_add_emr_steps 11-17T04:00:00+00:00 EmrCreateJobFlowOperator 11-18T04:00:42.410634+00:00 11-18T04:00:43.676077+00:00 0:00:01.265443 638055 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 11-18T04:00:38.000148+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_emr_steps 11-17T04:00:00+00:00 PythonOperator 11-18T04:00:19.516574+00:00 11-18T04:00:21.066604+00:00 0:00:01.550030 638050 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 11-18T04:00:16.013345+00:00 2 default_pool
success exchange-dsp-reporting_v002 check_cluster_status 11-16T04:00:00+00:00 EmrJobFlowSensor 11-17T04:01:06.271719+00:00 11-17T04:09:08.091242+00:00 0:08:01.819523 637479 airflow-worker-3.airflow-worker.data-eng.svc.cluster.local airflow 1 default 11-17T04:01:02.492556+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_cluster_and_add_emr_steps 11-16T04:00:00+00:00 EmrCreateJobFlowOperator 11-17T04:00:40.694466+00:00 11-17T04:00:41.771309+00:00 0:00:01.076843 637475 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 11-17T04:00:36.421253+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_emr_steps 11-16T04:00:00+00:00 PythonOperator 11-17T04:00:13.059366+00:00 11-17T04:00:16.117342+00:00 0:00:03.057976 637470 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 11-17T04:00:08.322556+00:00 2 default_pool
success exchange-dsp-reporting_v002 check_cluster_status 11-15T04:00:00+00:00 EmrJobFlowSensor 11-16T04:00:58.147040+00:00 11-16T04:10:00.302683+00:00 0:09:02.155643 636886 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 11-16T04:00:54.415171+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_cluster_and_add_emr_steps 11-15T04:00:00+00:00 EmrCreateJobFlowOperator 11-16T04:00:38.616864+00:00 11-16T04:00:40.389490+00:00 0:00:01.772626 636882 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 11-16T04:00:32.393037+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_emr_steps 11-15T04:00:00+00:00 PythonOperator 11-16T04:00:17.524079+00:00 11-16T04:00:19.721513+00:00 0:00:02.197434 636877 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 11-16T04:00:10.296141+00:00 2 default_pool
success exchange-dsp-reporting_v002 check_cluster_status 11-14T04:00:00+00:00 EmrJobFlowSensor 11-15T04:01:10.426153+00:00 11-15T04:09:12.263606+00:00 0:08:01.837453 636299 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 11-15T04:01:06.933461+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_cluster_and_add_emr_steps 11-14T04:00:00+00:00 EmrCreateJobFlowOperator 11-15T04:00:51.050564+00:00 11-15T04:00:52.140479+00:00 0:00:01.089915 636295 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 11-15T04:00:44.860100+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_emr_steps 11-14T04:00:00+00:00 PythonOperator 11-15T04:00:24.794218+00:00 11-15T04:00:27.014117+00:00 0:00:02.219899 636291 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 11-15T04:00:20.912395+00:00 2 default_pool
success exchange-dsp-reporting_v002 check_cluster_status 11-13T04:00:00+00:00 EmrJobFlowSensor 11-14T04:01:28.180200+00:00 11-14T04:09:30.954491+00:00 0:08:02.774291 635719 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 11-14T04:01:20.322324+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_cluster_and_add_emr_steps 11-13T04:00:00+00:00 EmrCreateJobFlowOperator 11-14T04:01:02.103696+00:00 11-14T04:01:03.724805+00:00 0:00:01.621109 635715 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 11-14T04:00:58.275052+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_emr_steps 11-13T04:00:00+00:00 PythonOperator 11-14T04:00:28.940222+00:00 11-14T04:00:30.315040+00:00 0:00:01.374818 635710 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 11-14T04:00:24.322741+00:00 2 default_pool
success exchange-dsp-reporting_v002 check_cluster_status 11-12T04:00:00+00:00 EmrJobFlowSensor 11-13T04:01:25.139413+00:00 11-13T04:08:26.859121+00:00 0:07:01.719708 635139 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 11-13T04:01:20.818047+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_cluster_and_add_emr_steps 11-12T04:00:00+00:00 EmrCreateJobFlowOperator 11-13T04:00:40.464492+00:00 11-13T04:00:41.463945+00:00 0:00:00.999453 635136 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 11-13T04:00:33.670895+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_emr_steps 11-12T04:00:00+00:00 PythonOperator 11-13T04:00:11.075577+00:00 11-13T04:00:12.351382+00:00 0:00:01.275805 635131 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 11-13T04:00:07.578669+00:00 2 default_pool
success exchange-dsp-reporting_v002 check_cluster_status 11-11T04:00:00+00:00 EmrJobFlowSensor 11-12T04:13:37.095034+00:00 11-12T04:13:37.801720+00:00 0:00:00.706686 634577 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 11-12T04:13:33.272047+00:00 3 default_pool
success exchange-dsp-reporting_v002 create_cluster_and_add_emr_steps 11-11T04:00:00+00:00 EmrCreateJobFlowOperator 11-12T04:00:33.308545+00:00 11-12T04:00:34.616865+00:00 0:00:01.308320 634562 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 11-12T04:00:29.390929+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_emr_steps 11-11T04:00:00+00:00 PythonOperator 11-12T04:00:08.664228+00:00 11-12T04:00:10.016806+00:00 0:00:01.352578 634558 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 11-12T04:00:05.329636+00:00 2 default_pool
success exchange-dsp-reporting_v002 check_cluster_status 11-10T04:00:00+00:00 EmrJobFlowSensor 11-11T04:00:52.519560+00:00 11-11T04:08:54.379575+00:00 0:08:01.860015 633963 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 11-11T04:00:48.980441+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_cluster_and_add_emr_steps 11-10T04:00:00+00:00 EmrCreateJobFlowOperator 11-11T04:00:42.307688+00:00 11-11T04:00:44.835267+00:00 0:00:02.527579 633962 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 11-11T04:00:26.962279+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_emr_steps 11-10T04:00:00+00:00 PythonOperator 11-11T04:00:08.855227+00:00 11-11T04:00:10.269639+00:00 0:00:01.414412 633957 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 11-11T04:00:04.952425+00:00 2 default_pool
success exchange-dsp-reporting_v002 check_cluster_status 11-09T04:00:00+00:00 EmrJobFlowSensor 11-10T04:01:16.435562+00:00 11-10T04:09:18.383662+00:00 0:08:01.948100 633369 airflow-worker-2.airflow-worker.data-eng.svc.cluster.local airflow 1 default 11-10T04:01:12.867938+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_cluster_and_add_emr_steps 11-09T04:00:00+00:00 EmrCreateJobFlowOperator 11-10T04:00:58.968921+00:00 11-10T04:01:00.896628+00:00 0:00:01.927707 633366 airflow-worker-2.airflow-worker.data-eng.svc.cluster.local airflow 2 default 11-10T04:00:52.865172+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_emr_steps 11-09T04:00:00+00:00 PythonOperator 11-10T04:00:25.681270+00:00 11-10T04:00:32.378362+00:00 0:00:06.697092 633360 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 11-10T04:00:08.780136+00:00 2 default_pool
success exchange-dsp-reporting_v002 check_cluster_status 11-08T04:00:00+00:00 EmrJobFlowSensor 11-09T04:13:08.035188+00:00 11-09T04:13:08.787243+00:00 0:00:00.752055 632782 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 11-09T04:13:04.576743+00:00 3 default_pool
success exchange-dsp-reporting_v002 create_cluster_and_add_emr_steps 11-08T04:00:00+00:00 EmrCreateJobFlowOperator 11-09T04:00:43.996360+00:00 11-09T04:00:45.236078+00:00 0:00:01.239718 632765 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 11-09T04:00:28.998176+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_emr_steps 11-08T04:00:00+00:00 PythonOperator 11-09T04:00:10.622344+00:00 11-09T04:00:13.021833+00:00 0:00:02.399489 632760 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 11-09T04:00:06.976244+00:00 2 default_pool
success exchange-dsp-reporting_v002 check_cluster_status 11-07T04:00:00+00:00 EmrJobFlowSensor 11-08T04:01:20.157273+00:00 11-08T04:09:22.116926+00:00 0:08:01.959653 632176 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 11-08T04:01:12.787127+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_cluster_and_add_emr_steps 11-07T04:00:00+00:00 EmrCreateJobFlowOperator 11-08T04:01:02.754592+00:00 11-08T04:01:05.380366+00:00 0:00:02.625774 632172 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 11-08T04:00:50.769084+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_emr_steps 11-07T04:00:00+00:00 PythonOperator 11-08T04:00:27.473999+00:00 11-08T04:00:35.211722+00:00 0:00:07.737723 632166 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 11-08T04:00:08.687543+00:00 2 default_pool
success exchange-dsp-reporting_v002 check_cluster_status 11-06T04:00:00+00:00 EmrJobFlowSensor 11-07T04:01:17.097033+00:00 11-07T04:10:19.099000+00:00 0:09:02.001967 631557 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 11-07T04:01:13.414118+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_cluster_and_add_emr_steps 11-06T04:00:00+00:00 EmrCreateJobFlowOperator 11-07T04:00:51.633358+00:00 11-07T04:00:52.588102+00:00 0:00:00.954744 631554 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 11-07T04:00:49.316074+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_emr_steps 11-06T04:00:00+00:00 PythonOperator 11-07T04:00:28.524116+00:00 11-07T04:00:29.888682+00:00 0:00:01.364566 631551 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 11-07T04:00:25.231312+00:00 2 default_pool
success exchange-dsp-reporting_v002 check_cluster_status 11-05T04:00:00+00:00 EmrJobFlowSensor 11-06T04:01:00.867077+00:00 11-06T04:09:02.819527+00:00 0:08:01.952450 631038 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 11-06T04:00:57.225819+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_cluster_and_add_emr_steps 11-05T04:00:00+00:00 EmrCreateJobFlowOperator 11-06T04:00:35.118144+00:00 11-06T04:00:36.054748+00:00 0:00:00.936604 631034 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 11-06T04:00:31.098117+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_emr_steps 11-05T04:00:00+00:00 PythonOperator 11-06T04:00:05.417785+00:00 11-06T04:00:06.816242+00:00 0:00:01.398457 631028 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 11-06T04:00:00.893994+00:00 2 default_pool
success exchange-dsp-reporting_v002 check_cluster_status 11-04T04:00:00+00:00 EmrJobFlowSensor 11-05T04:00:56.932947+00:00 11-05T04:08:58.807360+00:00 0:08:01.874413 630455 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 11-05T04:00:54.603305+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_cluster_and_add_emr_steps 11-04T04:00:00+00:00 EmrCreateJobFlowOperator 11-05T04:00:35.397995+00:00 11-05T04:00:36.358681+00:00 0:00:00.960686 630454 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 11-05T04:00:30.507795+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_emr_steps 11-04T04:00:00+00:00 PythonOperator 11-05T04:00:15.247284+00:00 11-05T04:00:17.157031+00:00 0:00:01.909747 630448 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 11-05T04:00:08.512310+00:00 2 default_pool
success exchange-dsp-reporting_v002 check_cluster_status 11-03T04:00:00+00:00 EmrJobFlowSensor 11-04T04:01:06.535133+00:00 11-04T04:10:08.481750+00:00 0:09:01.946617 629917 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 11-04T04:01:02.463694+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_cluster_and_add_emr_steps 11-03T04:00:00+00:00 EmrCreateJobFlowOperator 11-04T04:00:45.875200+00:00 11-04T04:00:46.871211+00:00 0:00:00.996011 629914 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 11-04T04:00:42.411905+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_emr_steps 11-03T04:00:00+00:00 PythonOperator 11-04T04:00:17.919161+00:00 11-04T04:00:19.527673+00:00 0:00:01.608512 629910 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 11-04T04:00:14.428514+00:00 2 default_pool
success exchange-dsp-reporting_v002 check_cluster_status 11-02T04:00:00+00:00 EmrJobFlowSensor 11-03T04:01:08.649081+00:00 11-03T04:09:10.398366+00:00 0:08:01.749285 629414 airflow-worker-2.airflow-worker.data-eng.svc.cluster.local airflow 1 default 11-03T04:01:06.302729+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_cluster_and_add_emr_steps 11-02T04:00:00+00:00 EmrCreateJobFlowOperator 11-03T04:00:46.949097+00:00 11-03T04:00:47.802977+00:00 0:00:00.853880 629412 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 11-03T04:00:44.309625+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_emr_steps 11-02T04:00:00+00:00 PythonOperator 11-03T04:00:21.545093+00:00 11-03T04:00:22.554181+00:00 0:00:01.009088 629409 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 11-03T04:00:18.237483+00:00 2 default_pool
success exchange-dsp-reporting_v002 check_cluster_status 11-01T04:00:00+00:00 EmrJobFlowSensor 11-02T04:00:56.203915+00:00 11-02T04:09:58.402378+00:00 0:09:02.198463 628931 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 11-02T04:00:52.697171+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_cluster_and_add_emr_steps 11-01T04:00:00+00:00 EmrCreateJobFlowOperator 11-02T04:00:28.381104+00:00 11-02T04:00:29.357823+00:00 0:00:00.976719 628928 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 11-02T04:00:24.705075+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_emr_steps 11-01T04:00:00+00:00 PythonOperator 11-02T04:00:05.264851+00:00 11-02T04:00:06.276133+00:00 0:00:01.011282 628924 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 11-02T04:00:02.632497+00:00 2 default_pool
success exchange-dsp-reporting_v002 check_cluster_status 10-31T04:00:00+00:00 EmrJobFlowSensor 11-01T04:00:53.505949+00:00 11-01T04:08:55.136109+00:00 0:08:01.630160 628439 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 11-01T04:00:50.804178+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_cluster_and_add_emr_steps 10-31T04:00:00+00:00 EmrCreateJobFlowOperator 11-01T04:00:27.566172+00:00 11-01T04:00:28.631346+00:00 0:00:01.065174 628436 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 11-01T04:00:24.812361+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_emr_steps 10-31T04:00:00+00:00 PythonOperator 11-01T04:00:05.270218+00:00 11-01T04:00:06.330106+00:00 0:00:01.059888 628432 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 11-01T04:00:02.633628+00:00 2 default_pool
success exchange-dsp-reporting_v002 check_cluster_status 10-30T04:00:00+00:00 EmrJobFlowSensor 10-31T04:13:00.579085+00:00 10-31T04:13:01.208483+00:00 0:00:00.629398 627961 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 10-31T04:12:56.617585+00:00 3 default_pool
success exchange-dsp-reporting_v002 create_cluster_and_add_emr_steps 10-30T04:00:00+00:00 EmrCreateJobFlowOperator 10-31T04:00:56.357607+00:00 10-31T04:00:57.296593+00:00 0:00:00.938986 627951 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 10-31T04:00:53.011467+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_emr_steps 10-30T04:00:00+00:00 PythonOperator 10-31T04:00:26.867872+00:00 10-31T04:00:27.830107+00:00 0:00:00.962235 627948 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 10-31T04:00:23.007564+00:00 2 default_pool
success exchange-dsp-reporting_v002 check_cluster_status 10-29T04:00:00+00:00 EmrJobFlowSensor 10-30T04:01:11.529162+00:00 10-30T04:10:13.182018+00:00 0:09:01.652856 627463 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 10-30T04:01:09.288747+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_cluster_and_add_emr_steps 10-29T04:00:00+00:00 EmrCreateJobFlowOperator 10-30T04:00:51.622444+00:00 10-30T04:00:52.463692+00:00 0:00:00.841248 627461 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 10-30T04:00:49.262709+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_emr_steps 10-29T04:00:00+00:00 PythonOperator 10-30T04:00:25.572623+00:00 10-30T04:00:26.494146+00:00 0:00:00.921523 627458 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 10-30T04:00:23.240591+00:00 2 default_pool
success exchange-dsp-reporting_v002 check_cluster_status 10-28T04:00:00+00:00 EmrJobFlowSensor 10-29T04:01:15.560692+00:00 10-29T04:08:17.027902+00:00 0:07:01.467210 626971 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 10-29T04:01:13.332540+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_cluster_and_add_emr_steps 10-28T04:00:00+00:00 EmrCreateJobFlowOperator 10-29T04:00:51.630223+00:00 10-29T04:00:53.239483+00:00 0:00:01.609260 626968 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 10-29T04:00:47.182136+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_emr_steps 10-28T04:00:00+00:00 PythonOperator 10-29T04:00:26.283772+00:00 10-29T04:00:27.860175+00:00 0:00:01.576403 626965 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 10-29T04:00:23.298433+00:00 2 default_pool
success exchange-dsp-reporting_v002 check_cluster_status 10-27T04:00:00+00:00 EmrJobFlowSensor 10-28T04:01:05.343336+00:00 10-28T04:09:06.921166+00:00 0:08:01.577830 626478 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 10-28T04:01:03.022317+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_cluster_and_add_emr_steps 10-27T04:00:00+00:00 EmrCreateJobFlowOperator 10-28T04:00:44.493096+00:00 10-28T04:00:45.519871+00:00 0:00:01.026775 626475 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 10-28T04:00:40.882621+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_emr_steps 10-27T04:00:00+00:00 PythonOperator 10-28T04:00:22.382965+00:00 10-28T04:00:23.716089+00:00 0:00:01.333124 626472 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 10-28T04:00:18.863312+00:00 2 default_pool
success exchange-dsp-reporting_v002 check_cluster_status 10-26T04:00:00+00:00 EmrJobFlowSensor 10-27T04:00:58.548761+00:00 10-27T04:08:00.010809+00:00 0:07:01.462048 625981 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 10-27T04:00:56.442492+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_cluster_and_add_emr_steps 10-26T04:00:00+00:00 EmrCreateJobFlowOperator 10-27T04:00:38.523918+00:00 10-27T04:00:39.505918+00:00 0:00:00.982000 625978 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 10-27T04:00:34.379459+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_emr_steps 10-26T04:00:00+00:00 PythonOperator 10-27T04:00:16.669164+00:00 10-27T04:00:17.576715+00:00 0:00:00.907551 625974 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 10-27T04:00:14.399346+00:00 2 default_pool
success exchange-dsp-reporting_v002 check_cluster_status 10-25T04:00:00+00:00 EmrJobFlowSensor 10-26T04:01:16.272628+00:00 10-26T04:10:18.241241+00:00 0:09:01.968613 625488 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 10-26T04:01:12.864465+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_cluster_and_add_emr_steps 10-25T04:00:00+00:00 EmrCreateJobFlowOperator 10-26T04:00:54.269938+00:00 10-26T04:00:55.221845+00:00 0:00:00.951907 625485 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 10-26T04:00:50.807290+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_emr_steps 10-25T04:00:00+00:00 PythonOperator 10-26T04:00:28.047673+00:00 10-26T04:00:29.247436+00:00 0:00:01.199763 625482 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 10-26T04:00:22.821485+00:00 2 default_pool
success exchange-dsp-reporting_v002 check_cluster_status 10-24T04:00:00+00:00 EmrJobFlowSensor 10-25T04:12:27.154561+00:00 10-25T04:12:27.664719+00:00 0:00:00.510158 625006 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 10-25T04:12:24.978572+00:00 3 default_pool
success exchange-dsp-reporting_v002 create_cluster_and_add_emr_steps 10-24T04:00:00+00:00 EmrCreateJobFlowOperator 10-25T04:00:44.634049+00:00 10-25T04:00:45.438171+00:00 0:00:00.804122 624996 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 10-25T04:00:42.552864+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_emr_steps 10-24T04:00:00+00:00 PythonOperator 10-25T04:00:18.879457+00:00 10-25T04:00:19.793749+00:00 0:00:00.914292 624993 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 10-25T04:00:16.523866+00:00 2 default_pool
success exchange-dsp-reporting_v002 check_cluster_status 10-23T04:00:00+00:00 EmrJobFlowSensor 10-24T04:00:54.914379+00:00 10-24T04:07:56.588423+00:00 0:07:01.674044 624500 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 10-24T04:00:51.328275+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_cluster_and_add_emr_steps 10-23T04:00:00+00:00 EmrCreateJobFlowOperator 10-24T04:00:32.852210+00:00 10-24T04:00:33.888165+00:00 0:00:01.035955 624498 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 10-24T04:00:29.326219+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_emr_steps 10-23T04:00:00+00:00 PythonOperator 10-24T04:00:09.502360+00:00 10-24T04:00:10.463078+00:00 0:00:00.960718 624494 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 10-24T04:00:07.130107+00:00 2 default_pool
success exchange-dsp-reporting_v002 check_cluster_status 10-22T04:00:00+00:00 EmrJobFlowSensor 10-23T04:01:10.838735+00:00 10-23T04:09:12.733451+00:00 0:08:01.894716 623992 airflow-worker-2.airflow-worker.data-eng.svc.cluster.local airflow 1 default 10-23T04:01:07.326440+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_cluster_and_add_emr_steps 10-22T04:00:00+00:00 EmrCreateJobFlowOperator 10-23T04:00:46.698936+00:00 10-23T04:00:47.723945+00:00 0:00:01.025009 623990 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 10-23T04:00:43.194933+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_emr_steps 10-22T04:00:00+00:00 PythonOperator 10-23T04:00:24.601729+00:00 10-23T04:00:26.108926+00:00 0:00:01.507197 623988 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 10-23T04:00:21.171972+00:00 2 default_pool
success exchange-dsp-reporting_v002 check_cluster_status 10-21T04:00:00+00:00 EmrJobFlowSensor 10-22T04:01:13.061923+00:00 10-22T04:09:14.933232+00:00 0:08:01.871309 623483 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 10-22T04:01:09.752631+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_cluster_and_add_emr_steps 10-21T04:00:00+00:00 EmrCreateJobFlowOperator 10-22T04:00:46.880359+00:00 10-22T04:00:47.852718+00:00 0:00:00.972359 623481 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 10-22T04:00:43.705704+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_emr_steps 10-21T04:00:00+00:00 PythonOperator 10-22T04:00:24.055548+00:00 10-22T04:00:25.027516+00:00 0:00:00.971968 623479 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 10-22T04:00:21.660053+00:00 2 default_pool
success exchange-dsp-reporting_v002 check_cluster_status 10-20T04:00:00+00:00 EmrJobFlowSensor 10-21T04:01:07.845816+00:00 10-21T04:08:09.282699+00:00 0:07:01.436883 622979 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 10-21T04:01:05.674977+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_cluster_and_add_emr_steps 10-20T04:00:00+00:00 EmrCreateJobFlowOperator 10-21T04:00:45.131186+00:00 10-21T04:00:46.115514+00:00 0:00:00.984328 622977 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 10-21T04:00:41.650663+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_emr_steps 10-20T04:00:00+00:00 PythonOperator 10-21T04:00:20.534046+00:00 10-21T04:00:21.437787+00:00 0:00:00.903741 622974 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 10-21T04:00:17.575085+00:00 2 default_pool
success exchange-dsp-reporting_v002 check_cluster_status 10-19T04:00:00+00:00 EmrJobFlowSensor 10-20T04:01:07.225021+00:00 10-20T04:09:09.114756+00:00 0:08:01.889735 622481 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 10-20T04:01:03.772928+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_cluster_and_add_emr_steps 10-19T04:00:00+00:00 EmrCreateJobFlowOperator 10-20T04:00:39.742264+00:00 10-20T04:00:40.575065+00:00 0:00:00.832801 622478 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 10-20T04:00:37.583557+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_emr_steps 10-19T04:00:00+00:00 PythonOperator 10-20T04:00:15.708106+00:00 10-20T04:00:16.717042+00:00 0:00:01.008936 622474 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 10-20T04:00:13.526550+00:00 2 default_pool
success exchange-dsp-reporting_v002 check_cluster_status 10-18T04:00:00+00:00 EmrJobFlowSensor 10-19T04:00:52.546512+00:00 10-19T04:07:54.066639+00:00 0:07:01.520127 621973 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 10-19T04:00:50.522794+00:00 2 default_pool