mirror of
https://github.com/jxxghp/MoviePilot.git
synced 2026-08-28 19:47:41 +08:00
Merge pull request #5383 from jxxghp/copilot/merge-agent-and-execution-messages
This commit is contained in:
+13
-7
@@ -39,11 +39,8 @@ class MoviePilotTool(BaseTool, metaclass=ABCMeta):
|
|||||||
"""
|
"""
|
||||||
异步运行工具
|
异步运行工具
|
||||||
"""
|
"""
|
||||||
# 发送和记忆工具调用前的信息
|
# 获取工具调用前的agent消息
|
||||||
agent_message = await self._callback_handler.get_message()
|
agent_message = await self._callback_handler.get_message()
|
||||||
if agent_message:
|
|
||||||
# 发送消息
|
|
||||||
await self.send_tool_message(agent_message, title="MoviePilot助手")
|
|
||||||
|
|
||||||
# 记忆工具调用
|
# 记忆工具调用
|
||||||
await conversation_manager.add_conversation(
|
await conversation_manager.add_conversation(
|
||||||
@@ -58,15 +55,24 @@ class MoviePilotTool(BaseTool, metaclass=ABCMeta):
|
|||||||
}
|
}
|
||||||
)
|
)
|
||||||
|
|
||||||
# 发送执行工具说明,优先使用工具自定义的提示消息,如果没有则使用 explanation
|
# 获取执行工具说明,优先使用工具自定义的提示消息,如果没有则使用 explanation
|
||||||
tool_message = self.get_tool_message(**kwargs)
|
tool_message = self.get_tool_message(**kwargs)
|
||||||
if not tool_message:
|
if not tool_message:
|
||||||
explanation = kwargs.get("explanation")
|
explanation = kwargs.get("explanation")
|
||||||
if explanation:
|
if explanation:
|
||||||
tool_message = explanation
|
tool_message = explanation
|
||||||
|
|
||||||
|
# 合并agent消息和工具执行消息,一起发送
|
||||||
|
messages = []
|
||||||
|
if agent_message:
|
||||||
|
messages.append(agent_message)
|
||||||
if tool_message:
|
if tool_message:
|
||||||
formatted_message = f"⚙️ => {tool_message}"
|
messages.append(f"⚙️ => {tool_message}")
|
||||||
await self.send_tool_message(formatted_message)
|
|
||||||
|
# 发送合并后的消息
|
||||||
|
if messages:
|
||||||
|
merged_message = "\n\n".join(messages)
|
||||||
|
await self.send_tool_message(merged_message, title="MoviePilot助手")
|
||||||
|
|
||||||
logger.debug(f'Executing tool {self.name} with args: {kwargs}')
|
logger.debug(f'Executing tool {self.name} with args: {kwargs}')
|
||||||
result = await self.run(**kwargs)
|
result = await self.run(**kwargs)
|
||||||
|
|||||||
Reference in New Issue
Block a user