From 4749ae6628d6d02063355abec61b5299f640b873 Mon Sep 17 00:00:00 2001 From: Agrim Khanna Date: Fri, 11 Jul 2025 10:09:36 +0530 Subject: [PATCH 1/3] removed log parsing from MD Work request polling --- ads/aqua/modeldeployment/deployment.py | 24 +----------------------- 1 file changed, 1 insertion(+), 23 deletions(-) diff --git a/ads/aqua/modeldeployment/deployment.py b/ads/aqua/modeldeployment/deployment.py index 9834eddd1..c3d3fdea5 100644 --- a/ads/aqua/modeldeployment/deployment.py +++ b/ads/aqua/modeldeployment/deployment.py @@ -757,7 +757,6 @@ def _create_deployment( logger.info( f"Aqua model deployment {deployment_id} created for model {aqua_model_id}. Work request Id is {deployment.dsc_model_deployment.workflow_req_id}" ) - status_list = [] progress_thread = threading.Thread( target=self.get_deployment_status, @@ -1301,37 +1300,17 @@ def get_deployment_status( poll_interval=DEFAULT_POLL_INTERVAL, ) except Exception: - status = "" - logs = deployment.show_logs().sort_values(by="time", ascending=False) - - if logs and len(logs) > 0: - status = logs.iloc[0]["message"] - - status = re.sub(r"[^a-zA-Z0-9]", " ", status) - if data_science_work_request._error_message: error_str = "" for error in data_science_work_request._error_message: error_str = error_str + " " + error.message error_str = re.sub(r"[^a-zA-Z0-9]", " ", error_str) - telemetry_kwargs = { - "ocid": ocid, - "model_name": model_name, - "work_request_error": error_str, - "status": status, - } - self.telemetry.record_event( - category=f"aqua/{model_type}/deployment/status", - action="FAILED", - **telemetry_kwargs, - ) - else: telemetry_kwargs = { "ocid": ocid, "model_name": model_name, - "status": status, + "work_request_error": error_str, } self.telemetry.record_event( @@ -1339,7 +1318,6 @@ def get_deployment_status( action="FAILED", **telemetry_kwargs, ) - else: telemetry_kwargs = {"ocid": ocid, "model_name": model_name} self.telemetry.record_event( From 056b44221e899882b486f19f75baeb04144482f5 Mon Sep 17 00:00:00 2001 From: Agrim Khanna Date: Fri, 11 Jul 2025 10:16:54 +0530 Subject: [PATCH 2/3] fixing test cases --- tests/unitary/with_extras/aqua/test_deployment.py | 1 - 1 file changed, 1 deletion(-) diff --git a/tests/unitary/with_extras/aqua/test_deployment.py b/tests/unitary/with_extras/aqua/test_deployment.py index da8830a77..7f129a9bd 100644 --- a/tests/unitary/with_extras/aqua/test_deployment.py +++ b/tests/unitary/with_extras/aqua/test_deployment.py @@ -2441,7 +2441,6 @@ def test_get_deployment_status_failed(self): self.assertEqual(kwargs["category"], f"aqua/{model_type}/deployment/status") self.assertEqual(kwargs["action"], "FAILED") self.assertIn("work_request_error", kwargs) - self.assertIn("status", kwargs) self.assertIn("ocid", kwargs) self.assertIn("model_name", kwargs) From 2a584b0361c9a286e6da822b61dd913165839f08 Mon Sep 17 00:00:00 2001 From: Agrim Khanna Date: Fri, 11 Jul 2025 10:28:30 +0530 Subject: [PATCH 3/3] updated toml file and release notes --- docs/source/release_notes.rst | 7 +++++++ pyproject.toml | 2 +- 2 files changed, 8 insertions(+), 1 deletion(-) diff --git a/docs/source/release_notes.rst b/docs/source/release_notes.rst index 20111554c..d3fe6def1 100644 --- a/docs/source/release_notes.rst +++ b/docs/source/release_notes.rst @@ -2,6 +2,13 @@ Release Notes ============= +2.13.14 +------- +Release date: Jul 10, 2025 + +* Resolve issues with AQUA telemetry reporting + + 2.13.13 ------- Release date: Jul 10, 2025 diff --git a/pyproject.toml b/pyproject.toml index 3eb1f931b..195f9d573 100644 --- a/pyproject.toml +++ b/pyproject.toml @@ -21,7 +21,7 @@ build-backend = "flit_core.buildapi" # Required name = "oracle_ads" # the install (PyPI) name; name for local build in [tool.flit.module] section below -version = "2.13.13" +version = "2.13.14" # Optional description = "Oracle Accelerated Data Science SDK"