From 7d0c33b033ecf2a649e39cb46d7c5dbc12d05bd0 Mon Sep 17 00:00:00 2001 From: Chris Tran Date: Fri, 13 Jun 2025 13:02:03 -0600 Subject: [PATCH] Use session_id for tracing temporary chats with Langfuse --- examples/filters/langfuse_filter_pipeline.py | 14 +++++++++++++- 1 file changed, 13 insertions(+), 1 deletion(-) diff --git a/examples/filters/langfuse_filter_pipeline.py b/examples/filters/langfuse_filter_pipeline.py index cd2c0ab..9daaac8 100644 --- a/examples/filters/langfuse_filter_pipeline.py +++ b/examples/filters/langfuse_filter_pipeline.py @@ -1,7 +1,7 @@ """ title: Langfuse Filter Pipeline author: open-webui -date: 2025-03-28 +date: 2025-06-16 version: 1.7 license: MIT description: A filter pipeline that uses Langfuse. @@ -126,6 +126,12 @@ class Pipeline: metadata = body.get("metadata", {}) chat_id = metadata.get("chat_id", str(uuid.uuid4())) + + # Handle temporary chats + if chat_id == "local": + session_id = metadata.get("session_id") + chat_id = f"temporary-session-{session_id}" + metadata["chat_id"] = chat_id body["metadata"] = metadata @@ -233,6 +239,12 @@ class Pipeline: self.log(f"Outlet function called with body: {body}") chat_id = body.get("chat_id") + + # Handle temporary chats + if chat_id == "local": + session_id = body.get("session_id") + chat_id = f"temporary-session-{session_id}" + metadata = body.get("metadata", {}) # Defaulting to 'llm_response' if no task is provided task_name = metadata.get("task", "llm_response")