refactor(chat): 使获取聊天流支持异步调用
This commit is contained in:
@@ -997,7 +997,7 @@ class MemorySystem:
|
|||||||
from src.chat.message_receive.chat_stream import get_chat_manager
|
from src.chat.message_receive.chat_stream import get_chat_manager
|
||||||
|
|
||||||
chat_manager = 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"):
|
if not chat_stream or not hasattr(chat_stream, "context_manager"):
|
||||||
logger.debug(f"未找到stream_id={stream_id}的聊天流或上下文管理器")
|
logger.debug(f"未找到stream_id={stream_id}的聊天流或上下文管理器")
|
||||||
|
|||||||
Reference in New Issue
Block a user