WorkflowStem.Engines.FlowEngine (workflow_stem v0.2.0)

Copy Markdown View Source

ALF-backed engine for :flow workflows.

Flow workflows are pure data pipelines: they accept arbitrary input events and run a sequence of transformations, producing a result and accumulating trace.

The :flow profile intentionally does not provide FSM-style state gating.

Summary

Types

runtime()

@type runtime() :: %{
  :execution_id => String.t(),
  :tenant_id => String.t(),
  :spec => map(),
  optional(:context) => map(),
  optional(:trace) => list(),
  optional(:blocked_reasons) => map(),
  optional(:breakpoint_hits) => list(),
  optional(:last_event) => {term(), term()} | nil,
  optional(:last_result) => term(),
  optional(:errors) => [map()],
  optional(:projection) => WorkflowStem.Projection.t()
}