From 8aa4451a0201f99f8206b0b41a930ae605b5a209 Mon Sep 17 00:00:00 2001 From: cfdaily Date: Fri, 22 May 2026 14:57:07 +0800 Subject: [PATCH] auto-sync: 2026-05-22 14:57:07 --- src/daemon/spawner.py | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/src/daemon/spawner.py b/src/daemon/spawner.py index 51a7f8d..6119c29 100644 --- a/src/daemon/spawner.py +++ b/src/daemon/spawner.py @@ -484,7 +484,7 @@ curl -X POST http://{api_host}:{api_port}/api/projects/{project_id}/tasks/{task_ agent_id, session_id) self._mark_task(db_path, task_id, "failed", {"reason": "session_stuck", "diagnostics": state}) - self._do_on_complete_async(on_complete, agent_id, "session_stuck") + await self._do_on_complete_async(on_complete, agent_id, "session_stuck") return # B2/B3/B4: 进程还活着 @@ -498,7 +498,7 @@ curl -X POST http://{api_host}:{api_port}/api/projects/{project_id}/tasks/{task_ "elapsed_seconds": monitor_timeout_count * int(self.agent_timeout), "diagnostics": state, }) - self._do_on_complete_async(on_complete, agent_id, "max_monitor_timeouts") + await self._do_on_complete_async(on_complete, agent_id, "max_monitor_timeouts") return # 未超限：继续等（不 release counter） @@ -524,7 +524,7 @@ curl -X POST http://{api_host}:{api_port}/api/projects/{project_id}/tasks/{task_ self._mark_task(db_path, task_id, "failed", { "reason": f"max_{retry_field}", "count": count, }) - self._do_on_complete_async(on_complete, agent_id, "max_retries") + await self._do_on_complete_async(on_complete, agent_id, "max_retries") return logger.info("Agent %s retry %s=%d/%d (session=%s)", @@ -557,7 +557,7 @@ curl -X POST http://{api_host}:{api_port}/api/projects/{project_id}/tasks/{task_ ) except Exception: logger.exception("Retry spawn failed for %s", agent_id) - self._do_on_complete_async(on_complete, agent_id, "retry_spawn_failed") + await self._do_on_complete_async(on_complete, agent_id, "retry_spawn_failed") # ── 辅助方法 ──