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

Merge 7d0c33b033 into adec65727e

Browse Source
This commit is contained in:
Chris Tran 2025-06-13 13:19:00 -06:00 committed by GitHub
commit 1774094ea2
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
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
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")