Crate af_workflow 

af-workflow — spec-driven workflow chassis.

A workflow is typed node expressions composed into a branched DAG. Port of agent_core/workflow/v2.

• Spec model (Spec, Branch, Node, Edge) — deserializes existing Python builtin JSON specs unchanged.
• Runtime — Event / StepResult / WorkflowContext / State and the StepNode trait (one event in, one result out).
• Registry (NodeRegistry) — maps node types to factories. Ships the generic node types via NodeRegistry::with_builtins; products register their own business types and side-effect guards.
• Durable host (WorkflowHost) — validates and compiles a branch DAG; claimed work is scheduled only by run_due_pass.

Re-exports

pub use event::Event;

pub use graph::primitive_kind;

pub use graph::render_graph;

pub use graph::render_graph_json;

pub use graph::GraphEdge;

pub use graph::GraphNode;

pub use graph::WorkflowGraph;

pub use host::HostError;

pub use host::WorkflowHost;

pub use host::ROOT_BRANCH;

pub use ingress::ingress_plans;

pub use ingress::next_cron_at;

pub use ingress::BranchIngressPlan;

pub use metrics::Readiness;

pub use metrics::RuntimeMetrics;

pub use node::StepNode;

pub use node::WorkflowContext;

pub use recorder::noop_recorder;

pub use recorder::NoopRecorder;

pub use recorder::RunHandle;

pub use recorder::RunRecorder;

pub use recorder::RunStatus;

pub use recorder::StepStatus;

pub use registry::FieldSpec;

pub use registry::FieldType;

pub use registry::NodeError;

pub use registry::NodeRegistry;

pub use registry::NodeSchema;

pub use registry::StepFactory;

pub use result::StepResult;

pub use spec::Branch;

pub use spec::Edge;

pub use spec::Node;

pub use spec::Spec;

pub use spec::SpecError;

pub use state::MemoryState;

pub use state::NamespacedState;

pub use state::State;

pub use supervisor::run_due_pass;

pub use supervisor::DriverOutcome;

pub use supervisor::DriverRegistry;

pub use supervisor::SupervisorSettings;

pub use supervisor::SupervisorStats;

pub use supervisor::WorkItem;

pub use supervisor::WorkQueue;

pub use supervisor::WorkflowDriver;

pub use template::resolve_config;

pub use template::TemplateError;

pub use validator::validate;

pub use validator::Violation;

Modules

builtins

Generic (non-business) node implementations.

event

Events flowing through a branch.

graph

Presentation-only workflow graph rendering for UI consumers.

host

Validated multi-branch workflow host.

ingress

Pure ingress planning helpers for durable workflow hosts.

metrics

Dependency-free scheduler metrics and readiness.

node

Node trait + context. Port of platform/node_protocol.py.

recorder

Infra-agnostic workflow run and step persistence seam.

registry

Node-type registry. Port of platform/registry.py.

result

What a step node returns. Port of platform/types.py Pass / Drop / FanOut.

spec

Workflow spec data model.

state

Branch-scoped run state.

supervisor

Database-agnostic scheduler for claimed long-running workflow instances.

template

$config.X / $instance.X / $event.X template resolution.

validator

Static spec validator. Port of platform/validator.py.

Structs

RunOutcome

Summary of one event driven through a compiled branch.

Enums

CompileError

Terminal

Where a run ended.