Crate atomr_agents_workflow 

Workflow engine. DAG of Steps; state is event-sourced and resumable.

Structs

Concurrency

Dag

Static structure of a workflow. Steps are stored separately from their adjacency to keep the runtime types simple.

FnInterruptStep

Closure-friendly InterruptibleStep.

FnStatefulStep

HumanApproval

InMemoryJournal

InputMapping

InterruptCtrl

Per-run interrupt control passed to a step. A step calls ctrl.interrupt(payload) to pause; on resume the runner returns the value from Command::Resume(...).

Interruptible

PlainStep

Adapter that turns any StatefulStep into an InterruptibleStep.

StatefulRunner

StepId

Subgraph

Subgraph-as-callable. Returns a JSON object with two keys: outputs (the projected output channels) and private_state (the full child snapshot, included when callers want to inspect child-only channels).

WorkflowRunner

WorkflowState

Enums

Command

JoinStrategy

PauseReason

RunOutcome

Step

One step in a workflow’s DAG.

WorkflowEvent

Events appended to the workflow’s journal. State is rebuilt by folding these in order.

Traits

BranchPredicate

Pure predicate over the workflow’s running state. Used by Branch and Loop.

InterruptibleStep

StatefulStep extension that gets the interrupt ctrl as well.

Journal

Pluggable journal abstraction. Phase 6 ships the in-memory implementation; production setups plug in a journal backed by atomr-persistence.

StatefulStep

Functions

dispatch_fan_out

Run producer to obtain a list of inputs, then dispatch each through target with at most concurrency running concurrently. Returns the per-input outputs in original order.