auto-sync: 2026-05-22 22:57:27

2026-05-22 22:57:27 +08:00
parent c4824da298
commit 596777a4ad
1 changed files with 5 additions and 0 deletions
@@ -133,6 +133,11 @@ class Blackboard:
                    conn.execute("SELECT retry_count FROM tasks WHERE id=?",
                                 (task_id,)).fetchone()["retry_count"] + 1
                )
+                # BUG-1: failed→pending 必须清空 assignee/claimed_at/current_agent
+                # 否则 dispatcher 会走确定性路由而非广播
+                updates["assignee"] = None
+                updates["claimed_at"] = None
+                updates["current_agent"] = None

            set_clause = ", ".join(f"{k}=?" for k in updates)
            conn.execute(