From 01ce69b3db03be45849f89b4aa8293ec16505907 Mon Sep 17 00:00:00 2001
From: Aviraj <100823015+avirajsingh7@users.noreply.github.com>
Date: Wed, 3 Sep 2025 10:50:07 +0530
Subject: [PATCH 1/2] add assistant id as tag in langfuse

---
 backend/app/api/routes/responses.py   | 1 +
 backend/app/core/langfuse/langfuse.py | 2 ++
 2 files changed, 3 insertions(+)

diff --git a/backend/app/api/routes/responses.py b/backend/app/api/routes/responses.py
index 8ecba92f..5a2821bb 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..3e294458 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(

From 73b8934f856d1044ef02df66c6b35a0b6fb48d70 Mon Sep 17 00:00:00 2001
From: Aviraj <100823015+avirajsingh7@users.noreply.github.com>
Date: Wed, 3 Sep 2025 10:55:13 +0530
Subject: [PATCH 2/2] precommit

---
 backend/app/api/routes/responses.py   | 2 +-
 backend/app/core/langfuse/langfuse.py | 4 ++--
 2 files changed, 3 insertions(+), 3 deletions(-)

diff --git a/backend/app/api/routes/responses.py b/backend/app/api/routes/responses.py
index 5a2821bb..94e5f19d 100644
--- a/backend/app/api/routes/responses.py
+++ b/backend/app/api/routes/responses.py
@@ -144,7 +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]
+        tags=[request.assistant_id],
     )
 
     tracer.start_generation(
diff --git a/backend/app/core/langfuse/langfuse.py b/backend/app/core/langfuse/langfuse.py
index 3e294458..81d636a6 100644
--- a/backend/app/core/langfuse/langfuse.py
+++ b/backend/app/core/langfuse/langfuse.py
@@ -55,7 +55,7 @@ def start_trace(
         name: str,
         input: Dict[str, Any],
         metadata: Optional[Dict[str, Any]] = None,
-        tags: list[str] | None = None
+        tags: list[str] | None = None,
     ):
         metadata = metadata or {}
         metadata["request_id"] = correlation_id.get() or "N/A"
@@ -65,7 +65,7 @@ def start_trace(
             input=input,
             metadata=metadata,
             session_id=self.session_id,
-            tags=tags ,
+            tags=tags,
         )
 
     def start_generation(