Crate zeph_orchestration 

Task orchestration: DAG execution, failure propagation, and persistence.

Re-exports

pub use aggregator::Aggregator;

pub use aggregator::LlmAggregator;

pub use cascade::CascadeConfig;

pub use cascade::CascadeDetector;

pub use cascade::RegionHealth;

pub use command::PlanCommand;

pub use error::OrchestrationError;

pub use graph::ExecutionMode;

pub use graph::FailureStrategy;

pub use graph::GraphId;

pub use graph::GraphPersistence;

pub use graph::GraphStatus;

pub use graph::TaskGraph;

pub use graph::TaskId;

pub use graph::TaskNode;

pub use graph::TaskResult;

pub use graph::TaskStatus;

pub use plan_cache::PlanCache;

pub use plan_cache::PlanCacheError;

pub use plan_cache::PlanTemplate;

pub use plan_cache::TemplateTask;

pub use plan_cache::normalize_goal;

pub use plan_cache::plan_with_cache;

pub use planner::LlmPlanner;

pub use planner::Planner;

pub use router::AgentRouter;

pub use router::RuleBasedRouter;

pub use scheduler::DagScheduler;

pub use scheduler::SchedulerAction;

pub use scheduler::TaskEvent;

pub use scheduler::TaskOutcome;

pub use topology::DispatchStrategy;

pub use topology::Topology;

pub use topology::TopologyAnalysis;

pub use topology::TopologyClassifier;

pub use verifier::Gap;

pub use verifier::GapSeverity;

pub use verifier::PlanVerifier;

pub use verifier::VerificationResult;

Modules

aggregator

Result aggregation: collect completed task outputs and synthesize a coherent summary.

cascade

Cascade-aware routing for DAG execution (arXiv:2603.17112).

command

dag

error

graph

plan_cache

Plan template caching for the LLM planner.

planner

LLM-based goal decomposition into a validated TaskGraph.

router

Agent routing: selects the best agent definition for a given task.

scheduler

DAG execution scheduler: drives task graph execution by emitting SchedulerAction commands.

topology

Heuristic topology classification for TaskGraph DAGs.

verifier

Post-task completeness verifier with targeted replan for detected gaps.