gardel/Mofox-Core
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix(affinity-chatter): 使用全局配置中的超时设置增强规划器的消息处理

Browse Source
This commit is contained in:
Windpicker-owo
2025-11-09 11:26:14 +08:00
parent c4c7c4ccc8
commit 4e971ccb22
1 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
src/plugins/built_in/affinity_flow_chatter/core/affinity_chatter.py
View File

@@ -16,6 +16,7 @@ from src.common.logger import get_logger
from src.plugin_system.base.base_chatter import BaseChatter from src.plugin_system.base.base_chatter import BaseChatter
from src.plugin_system.base.component_types import ChatType from src.plugin_system.base.component_types import ChatType
from src.plugins.built_in.affinity_flow_chatter.planner.planner import ChatterActionPlanner from src.plugins.built_in.affinity_flow_chatter.planner.planner import ChatterActionPlanner
from src.config.config import global_config
logger = get_logger("affinity_chatter") logger = get_logger("affinity_chatter")
@@ -73,7 +74,7 @@ class AffinityChatter(BaseChatter):
unread_messages = context.get_unread_messages() unread_messages = context.get_unread_messages()
# 使用增强版规划器处理消息 # 使用增强版规划器处理消息
actions, target_message = await self.planner.plan(context=context) actions, target_message = await asyncio.wait_for(self.planner.plan(context=context), global_config.chat.thinking_timeout)
self.stats["plans_created"] += 1 self.stats["plans_created"] += 1
# 执行动作（如果规划器返回了动作） # 执行动作（如果规划器返回了动作）