OpenWebUI/pipelines
1
0
Fork 0
mirror of https://github.com/open-webui/pipelines synced 2025-05-10 23:50:45 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

enh: langfuse filter

Browse Source
This commit is contained in:
Timothy J. Baek 2024-06-02 11:40:24 -07:00
parent 179c66db17
commit 5478b920df
1 changed files with 15 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
examples/filters/langfuse_filter_pipeline.py
View File

@ -101,3 +101,18 @@ class Pipeline:
print(trace.get_trace_url())
return body
async def outlet(self, body: dict, user: Optional[dict] = None) -> dict:
print(f"outlet:{__name__}")
trace = self.langfuse.trace(
name=f"filter:{__name__}",
input=body,
user_id=user["id"],
metadata={"name": user["name"]},
session_id=body["chat_id"],
)
print(trace.get_trace_url())
return body