Log workflow exceptions as error telemetry

Keep OliveRecipe focused on recipe outcome metadata and use the existing log_error path for workflow exceptions. This avoids duplicating exception fields on recipe events while preserving detailed formatted exception messages in error telemetry.

Files changed:

- olive/telemetry/telemetry_extensions.py

- olive/telemetry/telemetry.py

- olive/workflows/run/run.py

- test/workflows/test_workflow_run.py

Co-authored-by: Copilot <223556219+Copilot@users.noreply.github.com>

Author: bmehta001

olive/telemetry/telemetry.py

@@ -82,7 +82,6 @@
         "workflow_id",
         "config_overrides",
         "success",
-        "exception_type",
         "input_model_type",
         "input_model_source",
         "model_task",

olive/telemetry/telemetry_extensions.py

@@ -49,15 +49,12 @@ def log_recipe_result(
     recipe_name: str,
     success: bool,
     metadata: Optional[dict[str, Any]] = None,
-    exception_type: Optional[str] = None,
 ) -> None:
     telemetry = _get_logger()
     attributes = {
         "recipe_name": recipe_name,
         "success": success,
     }
-    if exception_type:
-        attributes["exception_type"] = exception_type
     telemetry.log(RECIPE_EVENT_NAME, attributes, metadata)
 
 

olive/workflows/run/run.py

@@ -21,7 +21,7 @@
 from olive.systems.common import SystemType
 from olive.telemetry.constants import SUPPRESS_WORKFLOW_TELEMETRY_ENV
 from olive.telemetry.telemetry import is_ci_environment
-from olive.telemetry.telemetry_extensions import log_recipe_result
+from olive.telemetry.telemetry_extensions import _format_exception_message, log_error, log_recipe_result
 from olive.workflows.run.config import RunConfig
 
 if TYPE_CHECKING:
@@ -213,7 +213,7 @@ def run(
 
     parsed_run_config = None
     success = False
-    exception_type = None
+    exception = None
     try:
         package_config = OlivePackageConfig.parse_file_or_obj(package_config)
         parsed_run_config = RunConfig.parse_file_or_obj(run_config)
@@ -238,9 +238,14 @@ def run(
         success = True
         return workflow_output
     except Exception as exc:
-        exception_type = type(exc).__name__
+        exception = exc
         raise
     finally:
+        if exception is not None:
+            log_error(
+                exception_type=type(exception).__name__,
+                exception_message=_format_exception_message(exception, exception.__traceback__),
+            )
         if os.environ.get(SUPPRESS_WORKFLOW_TELEMETRY_ENV) != "1":
             metadata = _build_recipe_result_metadata(
                 run_config,
@@ -252,7 +257,7 @@ def run(
                 package_config_provided=package_config_provided,
             )
             recipe_name = metadata.pop("recipe_name")
-            log_recipe_result(recipe_name, success=success, metadata=metadata, exception_type=exception_type)
+            log_recipe_result(recipe_name, success=success, metadata=metadata)
 
 
 def generate_files_from_packages(packages, file_name):

test/workflows/test_workflow_run.py

@@ -200,9 +200,10 @@ def test_run_logs_recipe_result_success(_, mock_run_engine, mock_log_recipe_resu
     assert config_overrides["systems"][0]["accelerators"][0]["execution_providers"] == ["CUDAExecutionProvider"]
 
 
+@patch("olive.workflows.run.run.log_error")
 @patch("olive.workflows.run.run.log_recipe_result")
 @patch("olive.workflows.run.run.run_engine")
-def test_run_logs_recipe_result_failure(mock_run_engine, mock_log_recipe_result):
+def test_run_logs_recipe_result_failure(mock_run_engine, mock_log_recipe_result, mock_log_error):
     config = {
         "input_model": {
             "type": "HfModel",
@@ -228,7 +229,10 @@ def test_run_logs_recipe_result_failure(mock_run_engine, mock_log_recipe_result)
     mock_log_recipe_result.assert_called_once()
     assert mock_log_recipe_result.call_args.args[0] == "Quantize"
     assert mock_log_recipe_result.call_args.kwargs["success"] is False
-    assert mock_log_recipe_result.call_args.kwargs["exception_type"] == "ValueError"
+    assert "exception_type" not in mock_log_recipe_result.call_args.kwargs
+    mock_log_error.assert_called_once()
+    assert mock_log_error.call_args.kwargs["exception_type"] == "ValueError"
+    assert "recipe failed" in mock_log_error.call_args.kwargs["exception_message"]
 
 
 @patch("olive.workflows.run.run.log_recipe_result")