WorkflowStem.Pipelines.Stepwise (workflow_stem v0.2.0)

Static ALF pipeline for :stepwise workflows.

This pipeline interprets the compiled spec (IR) in-band; we do not generate dynamic pipeline modules for disk-loaded workflows.

The stage order is defined in Mobus.Stepwise.SpecHelpers.pipeline_stage_modules/0 — both the foundation and workflow_stem pipelines reference the same list.

Summary

alf_components()

components()

start()

start(opts)

started?()

stop()

@spec call(any(), Keyword.t()) :: any() | [any()] | nil

@spec call(any(), Keyword.t()) :: reference()

@spec components() :: [map()]

@spec ensure_started(keyword()) :: :ok | {:error, term()}

@spec flow(map(), list(), Keyword.t()) :: Enumerable.t()

@spec start() :: :ok

@spec start(list()) :: :ok

@spec started?() :: true | false

@spec stop() :: :ok | {:exit, {atom(), any()}}

@spec stream(Enumerable.t(), Keyword.t()) :: Enumerable.t()