OpenWebUI/pipelines
1
0
Fork 0
mirror of https://github.com/open-webui/pipelines synced 2025-06-26 18:15:58 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

Use session_id for tracing temporary chats with Langfuse

Browse Source
This commit is contained in:
Chris Tran 2025-06-13 13:02:03 -06:00
parent adec65727e
commit 7d0c33b033
1 changed files with 13 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
examples/filters/langfuse_filter_pipeline.py
View File

@ -1,7 +1,7 @@
""" """
title: Langfuse Filter Pipeline title: Langfuse Filter Pipeline
author: open-webui author: open-webui
date: 2025-03-28 date: 2025-06-16
version: 1.7 version: 1.7
license: MIT license: MIT
description: A filter pipeline that uses Langfuse. description: A filter pipeline that uses Langfuse.
@ -126,6 +126,12 @@ class Pipeline:
metadata = body.get("metadata", {}) metadata = body.get("metadata", {})
chat_id = metadata.get("chat_id", str(uuid.uuid4())) 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 metadata["chat_id"] = chat_id
body["metadata"] = metadata body["metadata"] = metadata
@ -233,6 +239,12 @@ class Pipeline:
self.log(f"Outlet function called with body: {body}") self.log(f"Outlet function called with body: {body}")
chat_id = body.get("chat_id") 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", {}) metadata = body.get("metadata", {})
# Defaulting to 'llm_response' if no task is provided # Defaulting to 'llm_response' if no task is provided
task_name = metadata.get("task", "llm_response") task_name = metadata.get("task", "llm_response")