CMDCOrchestrator.DAG (cmdc_orchestrator v0.3.1)

DAG 定义：节点 + 边 + 拓扑排序。

Summary

edge_def()

边定义。

node_def()

node_type()

t()

返回拓扑分层结果：每一层内部所有节点彼此独立，可并行执行；层与层串行。

@type edge_def() :: %{
  :from => String.t(),
  :to => String.t(),
  optional(:label) => String.t() | nil,
  optional(:branch) => String.t() | nil
}

边定义。

:from / :to — 必填，节点 ID
:label — 可选展示名
:branch — 可选；若上游为 :router 节点，仅当 router 输出 %{route: branch} 时该边才被激活，其它分支会被剪枝（ADP 第 2 章 Routing）

@type node_def() :: %{id: String.t(), type: node_type(), config: map()}

@type node_type() :: :agent | :aggregator | :router | :gate | :debate | :hierarchy

@type t() :: %CMDCOrchestrator.DAG{
  edges: [edge_def()],
  id: String.t(),
  name: String.t(),
  nodes: [node_def()]
}

@spec get_dependencies(t(), String.t()) :: [String.t()]

@spec get_dependents(t(), String.t()) :: [String.t()]

@spec get_node(t(), String.t()) :: node_def() | nil

@spec layered_order(t()) :: {:ok, [[String.t()]]} | {:error, :cycle_detected}

返回拓扑分层结果：每一层内部所有节点彼此独立，可并行执行；层与层串行。

对应 Agentic Design Patterns 第 3 章 Parallelization 模式。

@spec topological_sort(t()) :: {:ok, [String.t()]} | {:error, :cycle_detected}