Airflow runs DAGs but requires Kubernetes. Temporal does durable execution but needs a server. GitHub Actions does CI but can't branch dynamically. Zapier connects triggers but can't roll back. Every tool requires infrastructure, and none is AI-native.
Universal orchestration engine for AI agents — workflows, pipelines, state machines, batch processing. 24 inventions, 124 MCP tools, .awf format. Rust core + MCP server.
ดาว
2
เครื่องมือ
—
อัปไทม์
—
The current fixes don't work. YAML pipelines are rigid -- you can't add a step at runtime. Cron schedulers don't know about holidays or service health. Retry logic is one-size-fits-all. Approval gates are yes/no checkboxes. And no orchestration tool lets your AI agent create, modify, and reason about the workflow itself.
AgenticWorkflow orchestrates every coordination pattern in a single engine. DAGs, state machines, batch processing, stream processing, fan-out/fan-in -- all through 124 MCP tools. Not "configure a YAML file." Your agent thinks about workflows -- plans them, validates them, executes them, retries intelligently, rolls back on failure, and learns from every execution.
Problems Solved (Read This First)
Problem: every orchestration tool requires infrastructure (Kubernetes, servers, cloud services).
Solved: single .awf binary file. Zero infrastructure. Works offline.
Problem: workflow tools handle one pattern (DAGs OR state machines OR batch, never all).
Solved: one engine for all patterns -- DAGs, FSMs, batch, stream, fan-out, triggers, schedules.
Problem: retries are "3 times with backoff" regardless of failure type.
Solved: failure-classified retry -- different strategies for rate limits, network errors, auth failures.
Problem: when step 5 fails, steps 1-4 leave partial results with no undo.
Solved: per-step rollback actions, executed in reverse order with cryptographic receipts.
Problem: "deploy to production" auto-executes with no human check.
Solved: approval gates with escalation chains, conditional auto-approval, and time-bounded decisions.
Problem: "what happened at 3am that broke production?" requires log archaeology.
Solved: structured, queryable audit trail. "Show all workflows that touched the billing DB."
use agentic_workflow::{Workflow, StepNode, StepType, Edge, EdgeType};
use agentic_workflow::engine::DagEngine;
let mut engine = DagEngine::new();
// Define a deployment pipeline
let mut wf = Workflow::new("deploy-pipeline", "Build, test, approve, deploy");
let build = StepNode::new("Build", StepType::Command {
command: "cargo".into(), args: vec!["build".into(), "--release".into()],
});
let test = StepNode::new("Test", StepType::Command {
command: "cargo".into(), args: vec!["test".into()],
});
let approve = StepNode::new("Approve", StepType::ApprovalGate {
approvers: vec!["[email protected]".into()], timeout_ms: Some(3600_000),
});
let deploy = StepNode::new("Deploy", StepType::McpTool {
sister: "connect".into(), tool: "deploy".into(),
params: serde_json::json!({"target": "production"}),
});
let (bid, tid, aid, did) = (build.id.clone(), test.id.clone(), approve.id.clone(), deploy.id.clone());
wf.add_step(build); wf.add_step(test); wf.add_step(approve); wf.add_step(deploy);
wf.add_edge(Edge { from: bid, to: tid.clone(), edge_type: EdgeType::Sequence });
wf.add_edge(Edge { from: tid, to: aid.clone(), edge_type: EdgeType::Sequence });
wf.add_edge(Edge { from: aid, to: did, edge_type: EdgeType::Sequence });
// Validate and execute
engine.register_workflow(wf).unwrap();
Four steps. One DAG. Approval gate before production. Retry intelligence. Rollback on failure. Works with Claude, Cursor, Windsurf, or any MCP client.
The 24 Capabilities
Six categories. Twenty-four capabilities. Every orchestration pattern that exists or will exist.
Core Engine (Capabilities 1-4)
#
Capability
What it solves
1
Universal DAG Engine
Every coordination pattern in one graph -- linear, parallel, conditional, loops
2
Execution Consciousness
Full execution awareness -- live status, progress, ETA, intervention
3
Intelligent Scheduling
Context-aware cron -- skip holidays, respect service health, learn optimal times
Workflow-of-workflows -- sequence, parallel, conditional operators on entire workflows
24
Workflow Collective
Share workflow patterns across teams with privacy verification
Benchmarks
Rust core. In-memory engines. Real numbers from stress tests:
Operation
Time
Scale
DAG validate + topological sort
<50ms
1,000 steps
Start executions
<100ms
100 concurrent
Batch creation
<500ms
10,000 items
Dead letter ingest + summary
<500ms
10,000 items
Idempotency store
<500ms
10,000 keys
Idempotency check
<200ms
10,000 keys
Audit record + query
<500ms
10,000 events
FSM transitions
<100ms
1,000 steps
.awf write + read
<200ms
100 workflows
Anomaly detection
<100ms
1,000 executions
Variable cascade
instant
1,000 depth
All stress tests measured on Apple ARM64, Rust 1.82, release profile. Every benchmark has a corresponding named test (stress_dag_1000_steps_linear_chain, stress_batch_10k_items, etc.).
Downloads pre-built awf and agentic-workflow-mcp binaries to ~/.local/bin/ and merges the MCP server into your Claude Desktop and Claude Code configs. If release artifacts are not available, the installer automatically falls back to cargo install --git source install.
Environment profiles (one command per environment):
# Desktop MCP clients (auto-merge Claude Desktop + Claude Code when detected)
curl -fsSL https://agentralabs.tech/install/workflow/desktop | bash
# Terminal-only (no desktop config writes)
curl -fsSL https://agentralabs.tech/install/workflow/terminal | bash
# Remote/server hosts (no desktop config writes)
curl -fsSL https://agentralabs.tech/install/workflow/server | bash
Any MCP-compatible client gets instant access to universal workflow orchestration. The agentic-workflow-mcp crate exposes the full engine over the Model Context Protocol (JSON-RPC 2.0 over stdio).
cargo install agentic-workflow-mcp
Configure Claude Desktop
Add to ~/Library/Application Support/Claude/claude_desktop_config.json:
Once connected, the LLM can create workflows, validate DAGs, execute pipelines, manage state machines, approve deployments, query audit trails, and predict execution outcomes -- all backed by the same .awf binary file.
# All workspace tests (unit + integration)
cargo test --workspace
# Stress tests only
cargo test -p agentic-workflow stress
# Single phase
cargo test -p agentic-workflow --test phase7_stress
Deployment Model
Standalone by default: AgenticWorkflow is independently installable and operable. Integration with AgenticMemory, AgenticCodebase, or other sisters is optional, never required.
Zero infrastructure: No databases, no cloud services, no Kubernetes. Single .awf file holds everything.
Area
Default behavior
Controls
Data storage
~/.local/share/agentic-workflow/
AWF_DATA_DIR
Log level
info
AWF_LOG=debug|info|warn|error
Transport
stdio (MCP default)
--transport sse for HTTP/SSE
Roadmap
Feature
Status
Step execution runners (shell, HTTP, MCP)
Planned
Distributed execution via gRPC
Planned
Expression language for conditionals
Planned
Real-time trigger integration (inotify, kqueue)
Planned
Python SDK
Planned
Docker image
Planned
The .awf File
Your agent's orchestration state. One file. Zero infrastructure.