DBT/clawgo
1
0
Fork 0
mirror of https://github.com/YspCoder/clawgo.git synced 2026-04-13 04:27:28 +08:00
Code Issues Packages Projects Releases Wiki Activity

autonomy loop fix: stop idle_round_budget wait/resume flapping and finalize tasks by audit outcome

Browse Source
This commit is contained in:
DBT
2026-02-28 14:57:52 +00:00
parent 35a2ea33c7
commit e729e50d02
1 changed files with 73 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

78
pkg/autonomy/engine.go
View File

@@ -292,6 +292,10 @@ func (e *Engine) tick() {
if st.BlockReason == "resource_lock" && !st.RetryAfter.IsZero() && now.Before(st.RetryAfter) {
continue
}
if st.BlockReason == "idle_round_budget" && e.opts.MaxRoundsWithoutUser > 0 && e.roundsWithoutUser >= e.opts.MaxRoundsWithoutUser {
// Stay waiting until user activity resets round budget.
continue
}
// Debounce waiting/resume flapping
if !st.WaitingSince.IsZero() && now.Sub(st.WaitingSince) < time.Duration(e.opts.WaitingResumeDebounceSec)*time.Second {
continue
@@ -307,6 +311,23 @@ func (e *Engine) tick() {
e.writeReflectLog("resume", st, fmt.Sprintf("autonomy resumed from waiting (reason=%s paused_for=%ds)", reason, pausedFor))
e.writeTriggerAudit("resume", st, reason)
}
if st.Status == "running" {
if outcome, ok := e.detectRunOutcome(st.ID, st.LastRunAt); ok {
e.releaseLocksLocked(st.ID)
if outcome == "success" || outcome == "suppressed" {
st.Status = "completed"
e.writeReflectLog("complete", st, "marked completed by run outcome")
continue
}
if outcome == "error" {
st.Status = "blocked"
st.BlockReason = "last_run_error"
st.RetryAfter = now.Add(blockedRetryBackoff(st.ConsecutiveStall+1, e.opts.MinRunIntervalSec))
e.sendFailureNotification(st, "last run ended with error")
continue
}
}
}
if st.Status == "blocked" {
e.releaseLocksLocked(st.ID)
if !st.RetryAfter.IsZero() && now.Before(st.RetryAfter) {
@@ -337,11 +358,13 @@ func (e *Engine) tick() {
}
if e.opts.MaxRoundsWithoutUser > 0 && e.roundsWithoutUser >= e.opts.MaxRoundsWithoutUser {
st.Status = "waiting"
st.BlockReason = "idle_round_budget"
st.WaitingSince = now
e.writeReflectLog("waiting", st, fmt.Sprintf("paused by idle round budget (%d)", e.opts.MaxRoundsWithoutUser))
e.writeTriggerAudit("waiting", st, "idle_round_budget")
if !(st.Status == "waiting" && st.BlockReason == "idle_round_budget") {
st.Status = "waiting"
st.BlockReason = "idle_round_budget"
st.WaitingSince = now
e.writeReflectLog("waiting", st, fmt.Sprintf("paused by idle round budget (%d)", e.opts.MaxRoundsWithoutUser))
e.writeTriggerAudit("waiting", st, "idle_round_budget")
}
continue
}
if !e.tryAcquireLocksLocked(st) {
@@ -987,6 +1010,51 @@ func (e *Engine) maybeCleanupTaskHistoryLocked(now time.Time) {
e.lastHistoryCleanupAt = now
}
func (e *Engine) detectRunOutcome(taskID string, since time.Time) (string, bool) {
if e.opts.Workspace == "" || taskID == "" {
return "", false
}
path := filepath.Join(e.opts.Workspace, "memory", "task-audit.jsonl")
f, err := os.Open(path)
if err != nil {
return "", false
}
defer f.Close()
sessionKey := "autonomy:" + taskID
latest := ""
latestAt := time.Time{}
s := bufio.NewScanner(f)
for s.Scan() {
var row map[string]interface{}
if json.Unmarshal(s.Bytes(), &row) != nil {
continue
}
if fmt.Sprintf("%v", row["session"]) != sessionKey {
continue
}
st := fmt.Sprintf("%v", row["status"])
if st == "" || st == "running" {
continue
}
ts := fmt.Sprintf("%v", row["time"])
tm, err := time.Parse(time.RFC3339, ts)
if err != nil {
continue
}
if !since.IsZero() && tm.Before(since) {
continue
}
if latestAt.IsZero() || tm.After(latestAt) {
latestAt = tm
latest = st
}
}
if latest == "" {
return "", false
}
return latest, true
}
func parseTodoAttributes(content string) (priority, dueAt, normalized string) {
priority = "normal"
normalized = content