ooodc/PicoBot
1
0
Fork 0
Code Pull Requests Activity

feat: 保存子智能体产生的所有消息到数据库，增强消息持久化功能

Browse Source
This commit is contained in:
oudecheng 2026-05-20 16:23:24 +08:00
parent 881c73c79f
commit 1dcdd24519
1 changed files with 14 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
src/tools/task/runtime.rs
View File

@ -188,6 +188,13 @@ impl DefaultSubAgentRuntime {
match result { match result {
Ok(Ok(process_result)) => { Ok(Ok(process_result)) => {
// 保存子智能体产生的所有消息到数据库
for message in &process_result.emitted_messages {
if let Err(e) = self.conversation_repository.append_message(&session.session_id, message) {
tracing::warn!(error = %e, session_id = %session.session_id, "Failed to append subagent message");
}
}
let final_message = process_result.final_response; let final_message = process_result.final_response;
Ok(TaskToolResult { Ok(TaskToolResult {
status: "success".to_string(), status: "success".to_string(),
@ -232,6 +239,13 @@ impl DefaultSubAgentRuntime {
match result { match result {
Ok(Ok(process_result)) => { Ok(Ok(process_result)) => {
// 保存子智能体产生的所有消息到数据库
for message in &process_result.emitted_messages {
if let Err(e) = self.conversation_repository.append_message(&session.session_id, message) {
tracing::warn!(error = %e, session_id = %session.session_id, "Failed to append subagent message");
}
}
let final_message = process_result.final_response; let final_message = process_result.final_response;
Ok(TaskToolResult { Ok(TaskToolResult {
status: "success".to_string(), status: "success".to_string(),