Method run

src/orchestration/scheduler.ts:221–275

Run the whole graph. Resolves when quiescent.

()

  /** Run the whole graph. Resolves when quiescent. */
  async run(): Promise<{ conflicts: ConflictRecord[] }> {
    // Initialize: nodes with no deps start ready.
    for (const node of this.graph.nodes.values()) {
      node.status = node.dependsOn.length === 0 ? 'ready' : 'pending';
    }

    const inFlight = new Set<Promise<void>>();

    while (!this.quiescent()) {
      if (this.opts.signal?.aborted) break;
      this.refreshStatuses();

      const slots = this.opts.maxConcurrency - inFlight.size;
      if (slots > 0) {
        const runnable = this.selectRunnable(slots);
        for (const node of runnable) {
          const p = this.processNode(node).finally(() => inFlight.delete(p));
          inFlight.add(p);
        }
      }

      if (inFlight.size === 0) {
        // Nothing running and nothing runnable — either done or deadlocked.
        this.refreshStatuses();
        if (this.selectRunnable(1).length === 0) break;
        continue;
      }

      // Wait for the next node to finish, then re-evaluate.
      await Promise.race(inFlight);
    }

    // Drain any stragglers.
    await Promise.allSettled(inFlight);

    // Final pass: any node still pending whose deps failed/blocked must be
    // marked blocked. We didn't reach these inside the loop because quiescent()
    // treats a pending-with-broken-deps node as non-advancing. Propagate
    // repeatedly so a chain (a fails → b blocked → c blocked) fully resolves.
    let changed = true;
    while (changed) {
      changed = false;
      for (const node of this.graph.nodes.values()) {
        if (node.status !== 'pending') continue;
        const broken = this.depsBroken(node);
        if (broken) {
          node.status = 'blocked';
          this.emit({ type: 'node-blocked', id: node.id, cause: broken });
          changed = true;
        }
      }
    }

    return { conflicts: this.conflicts };
  }

  statusCounts(): Record<TaskStatus, number> {
    const counts = {