From fe1fb1bf4e65e662ec81c52b512574dce3a854a5 Mon Sep 17 00:00:00 2001 From: cfdaily Date: Fri, 5 Jun 2026 00:12:43 +0800 Subject: [PATCH] auto-sync: 2026-06-05 00:12:43 --- src/daemon/spawner.py | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/src/daemon/spawner.py b/src/daemon/spawner.py index bdd7a61..b71228a 100644 --- a/src/daemon/spawner.py +++ b/src/daemon/spawner.py @@ -764,9 +764,10 @@ curl -X POST http://{api_host}:{api_port}/api/projects/{project_id}/tasks/{task_ # 广播任务：从 session 信息取真实 task_id 列表，逐一回调 tracker sess_info = self._sessions.get(session_id or "main", {}) bt_ids = sess_info.get("broadcast_task_ids") or [] - outcome_str = "claimed" if cls.get("status") == "ok" else "no_reply" + # 广播场景一律标 no_reply：Agent 只 claim 一个任务， + # 其余任务的 tracker 不能被 claimed 清除 for real_task_id in bt_ids: - self._ticker.record_broadcast_response(real_task_id, agent_id, outcome_str) + self._ticker.record_broadcast_response(real_task_id, agent_id, "no_reply") elif task_id and hasattr(self, '_ticker') and self._ticker: outcome_str = "claimed" if cls.get("status") == "ok" else "no_reply" self._ticker.record_broadcast_response(task_id, agent_id, outcome_str)