diff --git a/litellm/integrations/langfuse.py b/litellm/integrations/langfuse.py index 153b677e076..7a78befabac 100644 --- a/litellm/integrations/langfuse.py +++ b/litellm/integrations/langfuse.py @@ -470,7 +470,6 @@ class LangFuseLogger: generation_params = { "name": generation_name, "id": clean_metadata.pop("generation_id", generation_id), - "parent_observation_id": metadata.get("parent_observation_id"), "start_time": start_time, "end_time": end_time, "model": kwargs["model"], @@ -483,6 +482,10 @@ class LangFuseLogger: "version": clean_metadata.pop("version", None), } + parent_observation_id = metadata.get("parent_observation_id", None) + if parent_observation_id is not None: + generation_params["parent_observation_id"] = parent_observation_id + if supports_prompt: user_prompt = clean_metadata.pop("prompt", None) if user_prompt is None: