Expand description
Multi-agent orchestration engine with task queue, monitoring, and scheduling.
Implements the Orchestrator-Workers pattern for decomposing complex tasks into sub-tasks, dispatching them to specialized worker agents, and aggregating results with progress tracking and compliance hooks.
§Main types
Orchestrator— Top-level engine that decomposes and executes multi-agent pipelines.TaskQueue— Priority queue for distributing tasks to worker agents.AgentMonitor— Tracks agent health, metrics, and lifecycle.Scheduler— Cron-based job scheduler for recurring tasks.AgentProfile— Configuration profile defining an agent’s role and capabilities.
Re-exports§
pub use budget::default_budget;pub use budget::AgentUsage;pub use budget::AgentUsageEntry;pub use budget::BudgetStatus;pub use budget::BudgetSummary;pub use budget::BudgetTracker;pub use budget::TokenBudget;pub use deployment::DeploymentConfig;pub use deployment::DeploymentManager;pub use deployment::DeploymentStatus;pub use deployment::IssueSeverity;pub use deployment::ResourceLimits;pub use dev_team::DevRole;pub use dev_team::DevTeam;pub use dev_team::DevTeamConfig;pub use dev_team::DevWorkflow;pub use dev_team::QualityGate;pub use dev_team::WorkflowArtifact;pub use dev_team::WorkflowResult;pub use dev_team::WorkflowStatus;pub use dev_team::WorkflowStep;pub use engine::BackendFactory;pub use engine::Orchestrator;pub use engine::OrchestratorResult;pub use health::HealthCheckConfig;pub use health::HealthChecker;pub use health::HealthEvent;pub use message_bus::AgentMessage;pub use message_bus::BroadcastTarget;pub use message_bus::MessageBus;pub use message_bus::MessageType;pub use monitor::AgentMonitor;pub use patterns::describe_pattern;pub use patterns::estimate_cost;pub use patterns::validate_pattern;pub use patterns::AggregationStrategy;pub use patterns::CollaborationPattern;pub use patterns::PatternConfig;pub use patterns::PatternConfigBuilder;pub use patterns::PatternResult;pub use patterns::PipelineStage;pub use patterns::ReviewPolicy;pub use profiles::default_profiles;pub use registry::default_agent_definitions;pub use registry::AgentRegistry;pub use replanner::FailureContext;pub use replanner::RecoveryStrategy;pub use replanner::RecoveryTask;pub use replanner::ReplanEntry;pub use replanner::ReplanHistory;pub use replanner::Replanner;pub use scheduler::ScheduledJob;pub use scheduler::Scheduler;pub use spawner::SpawnRequest;pub use spawner::SubAgentSpawner;pub use task_queue::TaskQueue;pub use types::AgentMetrics;pub use types::AgentProfile;pub use types::AgentRole;pub use types::AgentState;pub use types::Artifact;pub use types::ArtifactKind;pub use types::Task;pub use types::TaskStatus;pub use types::WorkerStatus;pub use workflow::lead_qualification_workflow;pub use workflow::support_ticket_workflow;pub use workflow::FailureAction;pub use workflow::RunStatus;pub use workflow::StepCondition;pub use workflow::StepResult;pub use workflow::StepStatus;pub use workflow::StepType;pub use workflow::WorkflowDefinition;pub use workflow::WorkflowEngine;pub use workflow::WorkflowRun;pub use workflow::WorkflowStepDef;pub use workflow::WorkflowTrigger;pub use workflow_dsl::StepToml;pub use workflow_dsl::TemplateContext;pub use workflow_dsl::TriggerConfig;pub use workflow_dsl::ValidationError;pub use workflow_dsl::ValidationSeverity;pub use workflow_dsl::WorkflowDsl;pub use workflow_dsl::WorkflowMeta;pub use workflow_dsl::WorkflowToml;
Modules§
- agent_
versioning - Agent version management with deploy, rollback, and A/B traffic split. Agent version management for deploying, testing, and rolling back agent configurations.
- budget
- Token and resource budgeting per agent. Token and resource budgeting per agent.
- deployment
- Agent deployment lifecycle management. Agent deployment manager for handling the lifecycle of deployed agent instances.
- dev_
team - Pre-configured development team orchestration with workflows and quality gates. Development team orchestration module.
- engine
- Orchestration engine and pipeline execution.
- handoff
- Agent handoff protocol for sequential control transfer between specialized agents. Agent Handoff Protocol for sequential control transfer between agents.
- health
- Agent health monitoring with state machine transitions. Health check system for monitoring deployed agents.
- message_
bus - Inter-agent message bus for A2A communication. Inter-agent message bus for Agent-to-Agent (A2A) communication.
- monitor
- Agent health and metrics monitoring.
- patterns
- Advanced multi-agent collaboration patterns (Pipeline, Debate, Ensemble, etc.). Advanced multi-agent collaboration patterns.
- profiles
- Default agent profiles and role definitions.
- registry
- Agent registry with catalog management. Centralized agent registry that tracks all agent definitions, their capabilities, and deployment state.
- replanner
- Dynamic re-planning and failure recovery strategies. Dynamic re-planning for failed tasks.
- scheduler
- Cron-based job scheduler.
- spawner
- Sub-agent spawning utilities.
- task_
queue - Priority task queue.
- types
- Shared orchestration types (Task, AgentProfile, Artifact, etc.).
- workflow
- Configurable workflow engine for automating business pipelines. Configurable workflow engine for automating business pipelines.
- workflow_
dsl - TOML-based Workflow DSL for declarative pipeline definitions. TOML-based Workflow DSL for declarative pipeline definitions.