Reverting track md logs for error logging

ads/aqua/modeldeployment/deployment.py

@@ -769,7 +769,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,
@@ -1316,45 +1315,24 @@ 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(
                     category=f"aqua/{model_type}/deployment/status",
                     action="FAILED",
                     **telemetry_kwargs,
                 )
-
         else:
             telemetry_kwargs = {"ocid": ocid, "model_name": model_name}
             self.telemetry.record_event(

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

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"

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)