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

Dependency diagram orchestrata_ultimate.agents

API

No public API: the module defines no classes, functions or constants.

Source

Permalink: https://gitlab.com/MSamy/orchestrata-ultimate-architecture/-/blob/a4cbc2bdf/src/orchestrata_ultimate/agents/__init__.py

"""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",
]