Function spawnReadyPending

orchestrate/skills/orchestrate/scripts/core/loop.ts:123–150

(
  mgr: AgentManager,
  running: Promise<void>[]
)

}

async function spawnReadyPending(
  mgr: AgentManager,
  running: Promise<void>[]
): Promise<void> {
  await drainCommentRetryQueue({
    workspace: mgr.workspace,
    destinations: mgr.commentDestinations(),
    logAttention: line => mgr.logAttention(line),
    allowedSlackThread: mgr.plan.slackKickoffRef
      ? {
          channel: mgr.plan.slackKickoffRef.channel,
          threadTs: mgr.plan.slackKickoffRef.ts,
        }
      : undefined,
  });
  await mgr.andon.drainEvents();
  if (mgr.andon.isActive()) {
    mgr.andon.noteSpawnPaused();
    return;
  }
  for (const def of planTasks(mgr.plan)) {
    const s = mgr.getTask(def.name);
    if (!s || s.status !== "pending") continue;
    if (!mgr.depsSatisfied(s)) continue;
    const spawned = await mgr.spawnTask(def);
    if (spawned) running.push(mgr.waitAndHandoff(spawned));
  }
}

/**
 * Progress is possible iff some task is running OR at least one pending task