Sig.Schemas.NodeExecution (Sig v0.1.0)

Copy Markdown View Source

The record of one node within a workflow execution.

There is at most one record per node and execution. Available as execution.node_executions from Sig.get_execution/1.

Fields

  • :node_name - the node name in the workflow.
  • :module - the node module, as a string.
  • :status - "pending", "running", "retrying", "completed", "failed" or "skipped".
  • :attempts - number of attempts made so far.
  • :max_retries - maximum number of attempts.
  • :params - the node-level params.
  • :result - the node result, once completed.
  • :error - the error of the last failed attempt.
  • :started_at / :completed_at - timing of the node.

Summary

Types

t()

@type t() :: %Sig.Schemas.NodeExecution{
  __meta__: term(),
  attempts: non_neg_integer(),
  completed_at: DateTime.t() | nil,
  error: map() | nil,
  id: String.t() | nil,
  inserted_at: DateTime.t() | nil,
  max_retries: non_neg_integer(),
  module: String.t() | nil,
  node_name: String.t() | nil,
  params: map(),
  result: map() | nil,
  started_at: DateTime.t() | nil,
  status: String.t(),
  updated_at: DateTime.t() | nil,
  workflow_execution:
    Sig.Schemas.WorkflowExecution.t() | Ecto.Association.NotLoaded.t(),
  workflow_execution_id: String.t() | nil
}