auto-sync: 2026-05-22 14:57:07

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")
 
     # ── 辅助方法 ──