{"record":{"id":"119b19f92760d5d9","repo":"Hmbown/CodeWhale","slug":"fleet-coordination-state-is-busy-retry-resume","errorCode":null,"errorMessage":"Fleet coordination state is busy; retry resume","messagePattern":"Fleet coordination state is busy; retry resume","errorType":"exception","errorClass":null,"httpStatus":null,"severity":"error","filePath":"crates/tui/src/fleet/manager.rs","lineNumber":681,"sourceCode":"        // Reuse the shared scheduler recovery engine over the same ledger so\n        // resume and steady-state supervision converge on one store and one\n        // retry/escalation policy. The manager's `stale_after` becomes the\n        // scheduler's heartbeat timeout so both surfaces agree on staleness.\n        let policy = FleetSchedulerPolicy {\n            heartbeat_timeout: self.stale_after,\n            ..FleetSchedulerPolicy::default()\n        };\n        let mut scheduler = FleetScheduler::open(&self.workspace, policy)?;\n        scheduler.set_now(now);\n        // Keep the lock order coordination -> ledger. A restart generation is\n        // durably prepared by the callback before the scheduler publishes the\n        // replacement lease, and an exact one-generation-ahead preparation is\n        // safe to consume after a process crash.\n        let mut coordination_guard = match &self.sub_agent_manager {\n            Some(manager) => Some(\n                manager\n                    .try_write()\n                    .map_err(|_| anyhow!(\"Fleet coordination state is busy; retry resume\"))?,\n            ),\n            None => None,\n        };\n        let report = scheduler.resume_run_with_restart_callback(\n            run_id,\n            |state, task, task_spec, worker_id| {\n                if let Some(guard) = coordination_guard.as_mut() {\n                    self.prepare_registered_restart_generation(\n                        guard, state, task, task_spec, worker_id,\n                    )?;\n                }\n                Ok(())\n            },\n        )?;\n        let status = self.run_status(run_id)?;\n        Ok(FleetResumeReport {\n            run_id: run_id.clone(),\n            reclaimed_stale: report.marked_stale,","sourceCodeStart":663,"sourceCodeEnd":699,"githubUrl":"https://github.com/Hmbown/CodeWhale/blob/8880682c63083a91624de936797efa3ce9e498fd/crates/tui/src/fleet/manager.rs#L663-L699","documentation":"Error \"Fleet coordination state is busy; retry resume\" thrown in Hmbown/CodeWhale.","triggerScenarios":"Thrown at crates/tui/src/fleet/manager.rs:681 when the library encounters an invalid state.","commonSituations":"See trigger scenarios.","solutions":[],"exampleFix":null,"handlingStrategy":null,"validationCode":null,"typeGuard":null,"tryCatchPattern":null,"preventionTips":[],"tags":[],"backgroundTag":null,"analyzedSha":"8880682c63083a91624de936797efa3ce9e498fd","analyzedAt":"2026-08-16T11:31:27.956Z","schemaVersion":2},"datasetVersion":"2026-08-16T13:17:31.715Z"}