From 4770b657e15a25815eccf211f87843db356625e8 Mon Sep 17 00:00:00 2001
From: Chesars <cesarponce19544@gmail.com>
Date: Wed, 18 Mar 2026 22:05:27 -0300
Subject: [PATCH] =?UTF-8?q?refactor:=20extract=20duplicated=20stdout/stder?=
 =?UTF-8?q?r=20=E2=86=92=20logs=20logic=20to=20shared=20helper?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 litellm/llms/anthropic/chat/handler.py        | 15 ++-------------
 litellm/llms/anthropic/chat/transformation.py | 17 ++---------------
 litellm/types/responses/main.py               | 18 ++++++++++++++++++
 3 files changed, 22 insertions(+), 28 deletions(-)

diff --git a/litellm/llms/anthropic/chat/handler.py b/litellm/llms/anthropic/chat/handler.py
index 70ecf91725d..7dce72f1e82 100644
--- a/litellm/llms/anthropic/chat/handler.py
+++ b/litellm/llms/anthropic/chat/handler.py
@@ -50,7 +50,7 @@ from litellm.types.llms.openai import (
 )
 from litellm.types.responses.main import (
     OutputCodeInterpreterCall,
-    OutputCodeInterpreterCallLog,
+    build_code_interpreter_log_outputs,
 )
 from litellm.types.utils import (
     Delta,
@@ -708,20 +708,9 @@ class ModelResponseIterator:
                 continue
             call_id = tr.get("tool_use_id", "")
             content = tr.get("content", {})
-            if isinstance(content, dict):
-                parts = []
-                if content.get("stdout"):
-                    parts.append(content["stdout"])
-                if content.get("stderr"):
-                    parts.append(f"STDERR: {content['stderr']}")
-                logs = "".join(parts)
-            else:
-                logs = ""
+            log_outputs = build_code_interpreter_log_outputs(content)
             tool_input = self._server_tool_inputs.get(call_id, {})
             code = tool_input.get("command", "") if isinstance(tool_input, dict) else ""
-            log_outputs = (
-                [OutputCodeInterpreterCallLog(type="logs", logs=logs)] if logs else None
-            )
             results.append(
                 OutputCodeInterpreterCall(
                     type="code_interpreter_call",
diff --git a/litellm/llms/anthropic/chat/transformation.py b/litellm/llms/anthropic/chat/transformation.py
index ca101df0e95..bbc73fcfd40 100644
--- a/litellm/llms/anthropic/chat/transformation.py
+++ b/litellm/llms/anthropic/chat/transformation.py
@@ -61,7 +61,7 @@ from litellm.types.utils import (
 )
 from litellm.types.responses.main import (
     OutputCodeInterpreterCall,
-    OutputCodeInterpreterCallLog,
+    build_code_interpreter_log_outputs,
 )
 from litellm.utils import (
     ModelResponse,
@@ -1771,20 +1771,7 @@ class AnthropicConfig(AnthropicModelInfo, BaseConfig):
                         continue
                     call_id = tr.get("tool_use_id", "")
                     content = tr.get("content", {})
-                    if isinstance(content, dict):
-                        parts = []
-                        if content.get("stdout"):
-                            parts.append(content["stdout"])
-                        if content.get("stderr"):
-                            parts.append(f"STDERR: {content['stderr']}")
-                        logs = "".join(parts)
-                    else:
-                        logs = ""
-                    log_outputs = (
-                        [OutputCodeInterpreterCallLog(type="logs", logs=logs)]
-                        if logs
-                        else None
-                    )
+                    log_outputs = build_code_interpreter_log_outputs(content)
                     code_interpreter_results.append(
                         OutputCodeInterpreterCall(
                             type="code_interpreter_call",
diff --git a/litellm/types/responses/main.py b/litellm/types/responses/main.py
index e46857565c7..ebd2ad5b5a8 100644
--- a/litellm/types/responses/main.py
+++ b/litellm/types/responses/main.py
@@ -67,6 +67,24 @@ class OutputCodeInterpreterCall(BaseLiteLLMOpenAIResponseObject):
     outputs: Optional[List[OutputCodeInterpreterCallLog]]
 
 
+def build_code_interpreter_log_outputs(
+    content: Any,
+) -> Optional[List[OutputCodeInterpreterCallLog]]:
+    """Convert Anthropic bash_code_execution stdout/stderr to log outputs.
+
+    Shared by streaming (handler.py) and non-streaming (transformation.py) paths.
+    """
+    if not isinstance(content, dict):
+        return None
+    parts = []
+    if content.get("stdout"):
+        parts.append(content["stdout"])
+    if content.get("stderr"):
+        parts.append(f"STDERR: {content['stderr']}")
+    logs = "".join(parts)
+    return [OutputCodeInterpreterCallLog(type="logs", logs=logs)] if logs else None
+
+
 class GenericResponseOutputItem(BaseLiteLLMOpenAIResponseObject):
     """
     Generic response API output item