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)