fix: pipeline logs containing exceptions (#74)

Author: mathislucka

src/deepset_mcp/api/pipeline/models.py

@@ -62,6 +62,22 @@ class NoContentResponse(BaseModel):
     message: str = "No content"
 
 
+class TraceFrame(BaseModel):
+    """Model representing a single frame in a stack trace."""
+
+    filename: str
+    line_number: int
+    name: str
+
+
+class ExceptionInfo(BaseModel):
+    """Model representing exception information."""
+
+    type: str
+    value: str
+    trace: list[TraceFrame]
+
+
 class PipelineLog(BaseModel):
     """Model representing a single log entry from a pipeline."""
 
@@ -70,7 +86,7 @@ class PipelineLog(BaseModel):
     logged_at: datetime
     level: str
     origin: str
-    exceptions: str | None = None
+    exceptions: list[ExceptionInfo] | None = None
     extra_fields: dict[str, Any] = Field(default_factory=dict)
 
 

src/deepset_mcp/api/pipeline/resource.py

@@ -1,3 +1,4 @@
+import logging
 from typing import TYPE_CHECKING, Any
 
 from deepset_mcp.api.exceptions import UnexpectedAPIError
@@ -11,6 +12,8 @@
 )
 from deepset_mcp.api.transport import raise_for_status
 
+logger = logging.getLogger(__name__)
+
 if TYPE_CHECKING:
     from deepset_mcp.api.protocols import AsyncClientProtocol
 
@@ -199,6 +202,8 @@ async def get_logs(
             params=params,
         )
 
+        logger.warning(resp.json)
+
         raise_for_status(resp)
 
         if resp.json is not None:

src/deepset_mcp/tools/formatting_utils.py

@@ -124,7 +124,13 @@ def pipeline_logs_to_llm_readable_string(logs: PipelineLogList, pipeline_name: s
         ]
 
         if log.exceptions:
-            log_entry.append(f"- **Exceptions:** {log.exceptions}")
+            log_entry.append("- **Exceptions:**")
+            for exception in log.exceptions:
+                log_entry.append(f"- Type: {exception.type}")
+                log_entry.append(f"- Value: {exception.value}")
+                log_entry.append("- Traceback")
+                for frame in exception.trace:
+                    log_entry.append(f"- {frame.name} in line {frame.line_number} in file {frame.filename}")
 
         if log.extra_fields:
             log_entry.append("- **Extra Fields:")

test/unit/tools/test_formatting_utils.py

@@ -1,6 +1,7 @@
 from datetime import datetime
 
 from deepset_mcp.api.pipeline.models import (
+    ExceptionInfo,
     PipelineLog,
     PipelineLogList,
     PipelineValidationResult,
@@ -29,7 +30,7 @@ def test_pipeline_logs_to_llm_readable_string_with_logs() -> None:
         logged_at=datetime(2023, 1, 1, 12, 1, 30),
         level="error",
         origin="querypipeline",
-        exceptions="ValueError: Invalid document format",
+        exceptions=[ExceptionInfo(type="bla", value="bla", trace=[])],
         extra_fields={"component": "document_reader", "file_name": "test.pdf"},
     )
 
@@ -55,7 +56,7 @@ def test_pipeline_logs_to_llm_readable_string_with_logs() -> None:
     assert "**Timestamp:** January 01, 2023 12:01:30 PM" in result
     assert "**Level:** error" in result
     assert "**Message:** Error processing document" in result
-    assert "**Exceptions:** ValueError: Invalid document format" in result
+    assert "**Exceptions:**" in result
     assert "component: document_reader" in result
     assert "file_name: test.pdf" in result
 

test/unit/tools/test_pipeline.py

@@ -10,6 +10,7 @@
 from deepset_mcp.api.pipeline.log_level import LogLevel
 from deepset_mcp.api.pipeline.models import (
     DeepsetPipeline,
+    ExceptionInfo,
     NoContentResponse,
     PipelineLog,
     PipelineLogList,
@@ -446,7 +447,7 @@ async def test_get_pipeline_logs_success() -> None:
         logged_at=datetime(2023, 1, 1, 12, 1, 0),
         level="error",
         origin="querypipeline",
-        exceptions="ValueError: test error",
+        exceptions=[ExceptionInfo(type="bla", value="bla", trace=[])],
         extra_fields={"component": "reader"},
     )
     logs = PipelineLogList(data=[log1, log2], has_more=False, total=2)
@@ -461,7 +462,7 @@ async def test_get_pipeline_logs_success() -> None:
     assert "Error occurred" in result
     assert "**Level:** info" in result
     assert "**Level:** error" in result
-    assert "**Exceptions:** ValueError: test error" in result
+    assert "**Exceptions:**" in result
     assert "component: reader" in result