From 6137a6042ff050e2d0e01bf05b63f8a0c88dc217 Mon Sep 17 00:00:00 2001
From: Hassieb Pakzad <68423100+hassiebp@users.noreply.github.com>
Date: Tue, 1 Jul 2025 10:56:05 +0200
Subject: [PATCH 1/2] fix(anthropic): do not mutate when media present

---
 langfuse/_task_manager/media_manager.py | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

diff --git a/langfuse/_task_manager/media_manager.py b/langfuse/_task_manager/media_manager.py
index 43a50f8c6..a7cbd05d7 100644
--- a/langfuse/_task_manager/media_manager.py
+++ b/langfuse/_task_manager/media_manager.py
@@ -121,9 +121,10 @@ def _process_data_recursively(data: Any, level: int):
                     field=field,
                 )
 
-                data["data"] = media
+                copied = data.copy()
+                copied["data"] = media
 
-                return data
+                return copied
 
             # Vertex
             if (

From 48af701cbc8ada814ea348abc51e87ec5299af98 Mon Sep 17 00:00:00 2001
From: Hassieb Pakzad <68423100+hassiebp@users.noreply.github.com>
Date: Tue, 1 Jul 2025 11:09:00 +0200
Subject: [PATCH 2/2] push

---
 tests/test_openai.py | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/tests/test_openai.py b/tests/test_openai.py
index a1ef79a2e..86b0f057c 100644
--- a/tests/test_openai.py
+++ b/tests/test_openai.py
@@ -1,5 +1,6 @@
 import importlib
 import os
+from time import sleep
 
 import pytest
 from pydantic import BaseModel
@@ -36,6 +37,8 @@ def test_openai_chat_completion(openai):
 
     langfuse.flush()
 
+    sleep(1)
+
     generation = get_api().observations.get_many(
         name=generation_name, type="GENERATION"
     )