From 009dbc5efc0e0d060bf5baa6c19d70b66b71226d Mon Sep 17 00:00:00 2001 From: Lucas Oliveira Date: Fri, 5 Dec 2025 17:11:16 -0300 Subject: [PATCH] fix delete user conversation not being async --- src/agent.py | 4 ++-- src/services/chat_service.py | 2 +- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/src/agent.py b/src/agent.py index 203b6a74..dd092643 100644 --- a/src/agent.py +++ b/src/agent.py @@ -672,8 +672,8 @@ async def async_langflow_chat_stream( ) -def delete_user_conversation(user_id: str, response_id: str) -> bool: - """Delete a conversation for a user from both memory and persistent storage""" +async def delete_user_conversation(user_id: str, response_id: str) -> bool: + """Delete a conversation for a user from both memory and persistent storage (async, non-blocking)""" deleted = False try: diff --git a/src/services/chat_service.py b/src/services/chat_service.py index e965623c..92c834a8 100644 --- a/src/services/chat_service.py +++ b/src/services/chat_service.py @@ -595,7 +595,7 @@ class ChatService: try: # Delete from local conversation storage from agent import delete_user_conversation - local_deleted = delete_user_conversation(user_id, session_id) + local_deleted = await delete_user_conversation(user_id, session_id) # Delete from Langflow using the monitor API langflow_deleted = await self._delete_langflow_session(session_id)