Merge branch 'Th0rgal:master' into master

Author: adrienlacombe

src/api/supervision.rs

@@ -318,6 +318,13 @@ pub(crate) async fn stuck_mission_watchdog_loop(
     // previous tick. Entries for dead scopes are pruned each pass.
     let mut oom_seen: std::collections::HashMap<String, u64> = std::collections::HashMap::new();
 
+    // Worker missions we have already auto-resumed once this process lifetime.
+    // Auto-resume is a single supervised retry for workers whose runner died
+    // (orphan / deploy SIGTERM) — an environmental interruption, not the
+    // worker's own fault. If the resumed worker dies again it stays
+    // interrupted and the boss handles it, so this can never resume-storm.
+    let mut auto_resumed_workers: HashSet<Uuid> = HashSet::new();
+
     loop {
         tokio::time::sleep(CHECK_INTERVAL).await;
 
@@ -465,6 +472,39 @@ pub(crate) async fn stuck_mission_watchdog_loop(
                         .to_string(),
                 ),
             });
+
+            // One supervised auto-resume for orphaned WORKER missions. The
+            // boss used to babysit this by hand (10 manual resume_worker
+            // calls in one campaign); a runner death is environmental, so a
+            // single retry is safe. Once-only per process: a worker that dies
+            // again stays interrupted for the boss to triage.
+            if mission.parent_mission_id.is_some() && auto_resumed_workers.insert(mission.id) {
+                tracing::info!(
+                    mission_id = %mission.id,
+                    parent = ?mission.parent_mission_id,
+                    "Stuck-mission watchdog: auto-resuming orphaned worker once"
+                );
+                let (resume_tx, resume_rx) = oneshot::channel();
+                if cmd_tx
+                    .send(ControlCommand::ResumeMission {
+                        mission_id: mission.id,
+                        clean_workspace: false,
+                        skip_message: false,
+                        respond: resume_tx,
+                    })
+                    .await
+                    .is_ok()
+                {
+                    match resume_rx.await {
+                        Ok(Ok(_)) => {}
+                        Ok(Err(e)) => tracing::warn!(
+                            mission_id = %mission.id,
+                            "Auto-resume failed: {}; leaving interrupted for the boss", e
+                        ),
+                        Err(_) => {}
+                    }
+                }
+            }
         }
     }
 }