CMDCOrchestrator.NodeRun (cmdc_orchestrator v0.5.0)

Copy Markdown View Source

单个 workflow 节点的一次执行账本。

Summary

Functions

构造节点运行账本。

归一化节点状态。

Types

status()

@type status() ::
  :pending | :running | :waiting | :succeeded | :failed | :skipped | :cancelled

t()

@type t() :: %CMDCOrchestrator.NodeRun{
  actor_ref: String.t() | nil,
  attempts: non_neg_integer(),
  error: term() | nil,
  external_ref: String.t() | nil,
  finished_at: DateTime.t() | nil,
  id: String.t() | nil,
  input_snapshot: map(),
  metadata: map(),
  node_id: String.t(),
  node_type: atom() | String.t() | nil,
  output_data: term(),
  run_id: String.t(),
  signal: String.t() | nil,
  started_at: DateTime.t() | nil,
  status: status()
}

Functions

new(opts)

@spec new(keyword()) :: t()

构造节点运行账本。

normalize_status(status)

@spec normalize_status(status() | String.t()) :: status()

归一化节点状态。