diff --git a/backend/app/api/routes/responses.py b/backend/app/api/routes/responses.py index 8ecba92f..94e5f19d 100644 --- a/backend/app/api/routes/responses.py +++ b/backend/app/api/routes/responses.py @@ -144,6 +144,7 @@ def process_response( name="generate_response_async", input={"question": request.question, "assistant_id": request.assistant_id}, metadata={"callback_url": request.callback_url}, + tags=[request.assistant_id], ) tracer.start_generation( diff --git a/backend/app/core/langfuse/langfuse.py b/backend/app/core/langfuse/langfuse.py index b85903a3..81d636a6 100644 --- a/backend/app/core/langfuse/langfuse.py +++ b/backend/app/core/langfuse/langfuse.py @@ -55,6 +55,7 @@ def start_trace( name: str, input: Dict[str, Any], metadata: Optional[Dict[str, Any]] = None, + tags: list[str] | None = None, ): metadata = metadata or {} metadata["request_id"] = correlation_id.get() or "N/A" @@ -64,6 +65,7 @@ def start_trace( input=input, metadata=metadata, session_id=self.session_id, + tags=tags, ) def start_generation(