diff --git a/hive-c0re/src/coordinator.rs b/hive-c0re/src/coordinator.rs index d2473f3c..16e7d241 100644 --- a/hive-c0re/src/coordinator.rs +++ b/hive-c0re/src/coordinator.rs @@ -1452,12 +1452,11 @@ impl Coordinator { /// Ensure a runtime dir + (for sub-agents) per-agent socket exists. /// - /// **Prefer the split form:** + /// **Prefer the split form (event-driven):** /// - dir creation → `lifecycle::ensure_agent_runtime_dir(name)` - /// - listener registration → `register_agent(name)` (eagerly, on first - /// spawn) or leave it to `mcp_sockets::spawn_poll` (reconcile within - /// 10 s, safe for the start + rebuild paths where the container - /// takes longer than that to boot). + /// - listener registration → `register_agent(name)` at each explicit + /// lifecycle event (spawn, reconcile-start). `mcp_sockets::sync_on_start` + /// covers the daemon-restart case. /// /// This method is kept as a convenience shim for any remaining callers /// that need the combined semantics in one call. diff --git a/hive-c0re/src/job_queue/exec.rs b/hive-c0re/src/job_queue/exec.rs index ad9a99e2..51b35358 100644 --- a/hive-c0re/src/job_queue/exec.rs +++ b/hive-c0re/src/job_queue/exec.rs @@ -344,7 +344,7 @@ async fn run_drain(coord: &Arc, claim: &Claim, ctx: &Ctx<'_>) -> Re async fn run_write_dropin(coord: &Arc, claim: &Claim) -> Result { let name = &claim.agent; // write_dropins only needs the path value to build AgentPaths; the - // dir doesn't need to exist at this point (created by ensure_runtime + // dir doesn't need to exist at this point (created by ensure_agent_runtime_dir // on the upstream Prebuild/Start node). let agent_dir = Coordinator::agent_dir(name); let hive = coord.hive_env();