Method execute

src/orchestration/engine.ts:146–236

EXECUTE: run the DAG to completion.

(graph: TaskGraph, signal?: AbortSignal)

  /** EXECUTE: run the DAG to completion. */
  async execute(graph: TaskGraph, signal?: AbortSignal): Promise<ExecutionReport> {
    const started = Date.now();
    const staging = new StagingArea(this.opts.cwd);
    const qa = new QaNode(this.opts.qaHooks);
    const projGraph = await this.projectGraph();

    const slicerDeps: SlicerDeps = {
      cwd: this.opts.cwd,
      graph: projGraph,
      designTokens: this.opts.designTokens,
      // Staging-aware read: workers see committed-but-not-yet-on-disk content too.
      read: async (abs) => {
        try { return await fs.readFile(abs, 'utf-8'); } catch { return null; }
      },
    };

    let tokensSaved = 0;
    let totalToolCalls = 0;
    const conflicts: ConflictRecord[] = [];

    const hooks: SchedulerHooks = {
      runNode: async (node, sig) => {
        // 1. Slice the minimal context for this node.
        const ctx = await buildTaskContext(node, slicerDeps);
        const naive = await estimateNaiveTokens(node, slicerDeps);
        tokensSaved += Math.max(0, naive - ctx.estimatedTokens);

        // 2. Dispatch the worker (existing SubAgentRunner) with the role.
        const runner = getSubAgentRunner();
        if (!runner) return { taskId: node.id, ok: false, fileEdits: [], summary: '', toolCallsRun: 0, error: 'no runner' };

        const prompt = renderContextPrompt(ctx);
        const res = await runner(prompt, {
          maxIterations: 12,
          signal: sig,
          sessionId: `worker-${node.id}-${Date.now()}`,
          role: node.role,
        });
        totalToolCalls += res.toolCallsRun;

        // 3. Parse worker output into staged file edits.
        const fileEdits = await extractFileEdits(res.finalText, node, this.opts.cwd);
        return {
          taskId: node.id,
          ok: res.ok && fileEdits.length > 0,
          fileEdits,
          summary: res.finalText.slice(0, 500),
          modelUsed: res.modelUsed,
          toolCallsRun: res.toolCallsRun,
          error: res.ok ? (fileEdits.length === 0 ? 'worker produced no file edits' : undefined) : res.error,
        };
      },

      review: (node, result, sig) => qa.review(node, result, sig),

      dryRunMerge: async (node, result) => {
        const c = await staging.dryRunMerge(node, result);
        conflicts.push(...c);