diff --git a/src/daemon/ticker.py b/src/daemon/ticker.py index bbeb3d0..1663971 100644 --- a/src/daemon/ticker.py +++ b/src/daemon/ticker.py @@ -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"],