Use session id as the thread id

anajmi07 · anajmi07 · commit 7d86ded11cb8 · 2025-09-23T12:32:25.000+02:00
diff --git a/cx-agent-backend/src/infrastructure/adapters/langgraph_agent_service.py b/cx-agent-backend/src/infrastructure/adapters/langgraph_agent_service.py
@@ -164,7 +164,7 @@ async def process_request(self, request: AgentRequest) -> AgentResponse:
         else:
             config = RunnableConfig(
                 configurable={
-                    "thread_id": f"{request.user_id}_{request.session_id}",
+                    "thread_id": f"{request.session_id}",
                     "user_id": request.user_id,
                 },
             )
@@ -237,7 +237,7 @@ async def stream_response(self, request: AgentRequest):
         # Create config
         config = RunnableConfig(
             configurable={
-                "thread_id": f"{request.user_id}_{request.session_id}",
+                "thread_id": f"{request.session_id}",
                 "user_id": request.user_id,
             }
         )

Original file line number	Diff line number	Diff line change
`@@ -164,7 +164,7 @@ async def process_request(self, request: AgentRequest) -> AgentResponse:`
`164`	`164`	`else:`
`165`	`165`	`config = RunnableConfig(`
`166`	`166`	`configurable={`
`167`		`- "thread_id": f"{request.user_id}_{request.session_id}",`
	`167`	`+ "thread_id": f"{request.session_id}",`
`168`	`168`	`"user_id": request.user_id,`
`169`	`169`	`},`
`170`	`170`	`)`
`@@ -237,7 +237,7 @@ async def stream_response(self, request: AgentRequest):`
`237`	`237`	`# Create config`
`238`	`238`	`config = RunnableConfig(`
`239`	`239`	`configurable={`
`240`		`- "thread_id": f"{request.user_id}_{request.session_id}",`
	`240`	`+ "thread_id": f"{request.session_id}",`
`241`	`241`	`"user_id": request.user_id,`
`242`	`242`	`}`
`243`	`243`	`)`