x/tori
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix: comment on completed workflow resets to Planning phase with feedback

Browse Source
This commit is contained in:
Fam Zheng 2026-04-06 22:56:35 +01:00
parent f70328be0b
commit 2cb9d9321e
1 changed files with 13 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
src/agent.rs
View File

@ -204,7 +204,7 @@ impl AgentManager {
let mut initial_state = state_json let mut initial_state = state_json
.and_then(|json| serde_json::from_str::<crate::state::AgentState>(&json).ok()); .and_then(|json| serde_json::from_str::<crate::state::AgentState>(&json).ok());
// Attach comment as user feedback + reset failed/waiting steps // Prepare state for re-execution with user feedback
if let Some(ref mut state) = initial_state { if let Some(ref mut state) = initial_state {
for step in &mut state.steps { for step in &mut state.steps {
if matches!(step.status, crate::state::StepStatus::Failed) { if matches!(step.status, crate::state::StepStatus::Failed) {
@ -214,10 +214,20 @@ impl AgentManager {
step.status = crate::state::StepStatus::Running; step.status = crate::state::StepStatus::Running;
} }
} }
if let Some(order) = state.first_actionable_step() {
if state.first_actionable_step().is_some() {
// Has pending/failed steps — attach feedback and resume
let order = state.first_actionable_step().unwrap();
if let Some(step) = state.steps.iter_mut().find(|s| s.order == order) { if let Some(step) = state.steps.iter_mut().find(|s| s.order == order) {
step.user_feedbacks.push(content); step.user_feedbacks.push(content.clone());
} }
} else {
// All steps done — go back to Planning with user feedback
state.phase = crate::state::AgentPhase::Planning;
state.current_step_chat_history.clear();
state.current_step_chat_history.push(
crate::llm::ChatMessage::user(&format!("【用户反馈】{}", content))
);
} }
} }