Method decompose

src/orchestration/engine.ts:96–127

ORCHESTRATOR: produce the task DAG.

(goal: string, signal?: AbortSignal)

  /** ORCHESTRATOR: produce the task DAG. */
  async decompose(goal: string, signal?: AbortSignal): Promise<TaskGraph> {
    const raw = this.opts.planner
      ? await this.opts.planner(goal, signal)
      : await this.planViaModel(goal, signal);

    const nodes = new Map<TaskId, TaskNode>();
    for (const t of raw.tasks) {
      nodes.set(t.id, {
        id: t.id,
        kind: t.kind,
        title: t.title,
        instruction: t.instruction,
        targetFiles: t.targetFiles ?? [],
        contextFiles: t.contextFiles ?? [],
        contextSymbols: t.contextSymbols,
        dependsOn: t.dependsOn ?? [],
        role: defaultRoleForKind(t.kind),
        visualReview: t.visualReview ?? false,
        status: 'pending',
        attempts: 0,
      });
    }

    const graph: TaskGraph = { nodes, goal, acyclic: false };
    const order = topoSort(graph);
    if (!order) {
      throw new Error('Planner produced a cyclic task graph; cannot schedule. Re-plan with acyclic dependencies.');
    }
    graph.acyclic = true;
    logger.info('Decomposed goal into DAG', { tasks: nodes.size, order });
    return graph;
  }

  /** Ask the planning model for the DAG as JSON. */
  private async planViaModel(goal: string, signal?: AbortSignal): Promise<RawPlan> {