SquidMesh.Runtime.StepExecutor.Preparation (squid_mesh v0.1.0-alpha.3)

Prepares a runnable workflow step for execution.

This phase resolves which step a worker is allowed to execute, ensures the run is in the correct lifecycle state, claims durable step-run state, and builds the normalized input that execution will consume.

Summary

Types

prepare_result()

Functions

prepare(config, definition, run, expected_step)

Types

prepare_result()

@type prepare_result() ::
  {:execute, SquidMesh.Runtime.StepExecutor.PreparedStep.t()}
  | {:reconcile, SquidMesh.Runtime.StepExecutor.PreparedStep.t()}
  | {:skip, SquidMesh.Runtime.StepExecutor.PreparedStep.t()}
  | {:cancel, SquidMesh.Run.t()}
  | :skip
  | {:error, term()}

Functions

prepare(config, definition, run, expected_step)

@spec prepare(
  SquidMesh.Config.t(),
  SquidMesh.Workflow.Definition.t(),
  SquidMesh.Run.t(),
  atom() | nil
) ::
  prepare_result()