refactor(chat): 优化异步任务处理和参数传递机制
- 重构ExpressionSelector初始化,添加chat_id参数支持 - 优化StreamLoopManager中异步任务的创建和管理方式 - 简化MessageManager中的消息添加流程 - 调整Prompt中表情选择器的参数传递结构
This commit is contained in:
@@ -89,9 +89,8 @@ class MessageManager:
|
||||
logger.warning(f"MessageManager.add_message: 聊天流 {stream_id} 不存在")
|
||||
return
|
||||
await self._check_and_handle_interruption(chat_stream)
|
||||
chat_stream.context_manager.context.processing_task = asyncio.create_task(
|
||||
chat_stream.context_manager.add_message(message)
|
||||
)
|
||||
await chat_stream.context_manager.add_message(message)
|
||||
|
||||
except Exception as e:
|
||||
logger.error(f"添加消息到聊天流 {stream_id} 时发生错误: {e}")
|
||||
|
||||
|
||||
Reference in New Issue
Block a user