orchestrata_ultimate.agents
Reference › orchestrata_ultimate › agents › init
The package entry of the Multi-Agent Runtime (94 lines). It re-exports the public surface from constants, exceptions, interfaces and types, and defines no classes or functions of its own. Concrete components such as the runtime, pool and executor are imported from their own modules. See the package page.
At a glance
| Source | src/orchestrata_ultimate/agents/__init__.py |
| Lines of code | 94 |
| Classes | 0 |
| Functions | 0 |
| Imports (internal) | orchestrata_ultimate.agents.constants, orchestrata_ultimate.agents.exceptions, orchestrata_ultimate.agents.interfaces, orchestrata_ultimate.agents.types |
| Imported by | none |
| Tests that import it | tests/agents/test_constants.py, tests/agents/test_task_executor.py, tests/agents/test_task_executor_coverage.py |
Class diagram
No classes; see Functions.
Dependency diagram
API
No public API: the module defines no classes, functions or constants.
Source
"""Multi-Agent Runtime for Orchestrata.
Provides Volk lifecycle management, task execution, pool management,
multi-Volk coordination, and integration with Intent Broker, Postman,
CXP, and the DI container.
Author: Mohamed
Spec: 005-multi-agent (amended)
"""
from orchestrata_ultimate.agents.constants import (
DEFAULT_HEARTBEAT_INTERVAL_SECONDS,
DEFAULT_IDLE_TIMEOUT_SECONDS,
DEFAULT_POOL_MAX,
DEFAULT_POOL_MIN,
DEFAULT_SPAWN_TIMEOUT_MS,
DEFAULT_TASK_TIMEOUT_SECONDS,
PROLOG_MODULE,
REDIS_TASK_PREFIX,
REDIS_VOLK_INSTANCE_PREFIX,
)
from orchestrata_ultimate.agents.exceptions import (
ConsensusError,
CoordinationError,
LeaderElectionError,
PoolExhaustedError,
PoolScaleError,
PrologBridgeError,
TaskAssignmentError,
TaskCancellationError,
TaskExecutionError,
VolkRuntimeError,
VolkSpawnError,
VolkTerminateError,
)
from orchestrata_ultimate.agents.interfaces import (
ITaskExecutor,
IVolkCoordinator,
IVolkPool,
IVolkRuntime,
)
from orchestrata_ultimate.agents.types import (
ConsensusResult,
CoordinationPattern,
InstanceStatus,
PoolConfig,
PoolStatus,
TaskDefinition,
TaskResult,
TaskStatus,
VolkInstance,
)
__all__ = [
# Enums
"InstanceStatus",
"TaskStatus",
"CoordinationPattern",
# Dataclasses
"TaskDefinition",
"TaskResult",
"VolkInstance",
"PoolConfig",
"PoolStatus",
"ConsensusResult",
# Interfaces
"IVolkRuntime",
"ITaskExecutor",
"IVolkPool",
"IVolkCoordinator",
# Exceptions
"VolkRuntimeError",
"VolkSpawnError",
"VolkTerminateError",
"TaskExecutionError",
"TaskAssignmentError",
"TaskCancellationError",
"PoolExhaustedError",
"PoolScaleError",
"CoordinationError",
"LeaderElectionError",
"ConsensusError",
"PrologBridgeError",
# Constants
"DEFAULT_POOL_MIN",
"DEFAULT_POOL_MAX",
"DEFAULT_IDLE_TIMEOUT_SECONDS",
"DEFAULT_TASK_TIMEOUT_SECONDS",
"DEFAULT_SPAWN_TIMEOUT_MS",
"DEFAULT_HEARTBEAT_INTERVAL_SECONDS",
"REDIS_VOLK_INSTANCE_PREFIX",
"REDIS_TASK_PREFIX",
"PROLOG_MODULE",
]