auto-sync: 2026-05-17 21:44:06

2026-05-17 21:44:06 +08:00
parent 4c83a7ccd7
commit d53e836a55
1 changed files with 7 additions and 1 deletions
@@ -323,7 +323,7 @@ class Ticker:
                    project_config={"project_id": project_id, "db_path": db_path},
                )
                if result["status"] == "dispatched" and result["level"] in ("full", "escalate"):
-                    # 标记为 claimed
+                    # 标记为 claimed + 更新 current_agent
                    conn = get_connection(db_path)
                    try:
                        ok = self._transition_status(
@@ -333,6 +333,12 @@ class Ticker:
                                    "session_id": result.get("session_id")},
                        )
                        if ok:
+                            # 更新 current_agent（Router 审查时用）
+                            conn.execute(
+                                "UPDATE tasks SET current_agent=? WHERE id=?",
+                                (result["agent_id"], task.id),
+                            )
+                            conn.commit()
                            dispatched.append(task.id)
                            logger.info("Dispatched %s to %s (session=%s)",
                                        task.id, result["agent_id"],