Function runOrchestrateLoop

orchestrate/skills/orchestrate/scripts/core/loop.ts:32–83

(
  mgr: AgentManager,
  options: RunLoopOptions = {}
)

 * recovery path; use `kill` explicitly if you want to converge a broken tree.
 */
export async function runOrchestrateLoop(
  mgr: AgentManager,
  options: RunLoopOptions = {}
): Promise<number> {
  const running: Promise<void>[] = [];
  const maxRuntimeSec = options.maxRuntimeSec ?? DEFAULT_MAX_RUNTIME_SEC;
  const rootMode = options.rootMode ?? false;
  const exitOnError = options.exitOnError ?? true;
  const now = options.now ?? Date.now;
  const sleepFn = options.sleep ?? sleep;
  const startedAt = now();
  // Pre-existing errors (respawned-but-still-failed, pruned-siblings)
  // must not short-circuit the first sweep; only new transitions do.
  const preExistingErrors = new Set(
    mgr.tasks.filter(s => s.status === "error").map(s => s.name)
  );

  for (const s of mgr.tasks) {
    if (s.status === "running") {
      const rec = await mgr.recoverRunning(s);
      if (rec) running.push(mgr.waitAndHandoff(rec));
    }
  }

  if (exitOnError && hasNewTerminalError(mgr, preExistingErrors)) {
    return exitOnErrorReturn(mgr, preExistingErrors);
  }

  while (true) {
    await spawnReadyPending(mgr, running);
    printSweepHeartbeat(mgr);
    if (exitOnError && hasNewTerminalError(mgr, preExistingErrors)) {
      return exitOnErrorReturn(mgr, preExistingErrors);
    }
    const progressPossible = canMakeProgress(mgr);
    const elapsedMs = now() - startedAt;
    if (progressPossible && elapsedMs >= maxRuntimeSec * 1000) {
      const elapsedSec = Math.floor(elapsedMs / 1000);
      return plannedCheckpointRestart(mgr, elapsedSec, rootMode);
    }
    if (!progressPossible) break;
    const remainingRuntimeMs = maxRuntimeSec * 1000 - elapsedMs;
    await sleepFn(
      Math.min(SPAWN_SWEEP_INTERVAL_MS, Math.max(1, remainingRuntimeMs))
    );
  }
  await Promise.allSettled(running);

  flagUnreachablePending(mgr);
  printLoopSummary(mgr);
  return computeLoopExitCode(mgr);
}

function plannedCheckpointRestart(
  mgr: AgentManager,