diff --git a/src/chat/memory_system/memory_system.py b/src/chat/memory_system/memory_system.py
index a2c0a0e83..e1494a83e 100644
--- a/src/chat/memory_system/memory_system.py
+++ b/src/chat/memory_system/memory_system.py
@@ -997,7 +997,7 @@ class MemorySystem:
             from src.chat.message_receive.chat_stream import get_chat_manager
 
             chat_manager = get_chat_manager()
-            chat_stream = chat_manager.get_stream(stream_id)
+            chat_stream = await chat_manager.get_stream(stream_id)
 
             if not chat_stream or not hasattr(chat_stream, "context_manager"):
                 logger.debug(f"未找到stream_id={stream_id}的聊天流或上下文管理器")