Skip to main content

atomr_agents_workflow/
lib.rs

1//! Workflow engine. DAG of `Step`s; state is event-sourced and
2//! resumable.
3
4mod dag;
5mod dispatch;
6mod event;
7mod interrupt;
8mod runner;
9mod state_runner;
10mod step;
11mod subgraph;
12
13pub use dispatch::dispatch_fan_out;
14pub use subgraph::Subgraph;
15
16pub use dag::{Dag, StepId};
17pub use event::{InMemoryJournal, Journal, WorkflowEvent};
18pub use interrupt::{
19    Command, FnInterruptStep, InterruptCtrl, Interruptible, InterruptibleStep, PauseReason, PlainStep,
20    RunOutcome,
21};
22pub use runner::{WorkflowRunner, WorkflowState};
23pub use state_runner::{FnStatefulStep, StatefulRunner, StatefulStep};
24pub use step::{BranchPredicate, Concurrency, HumanApproval, InputMapping, JoinStrategy, Step};