Orchestra API

from marsys.coordination import Orchestra
from marsys.coordination.orchestra import OrchestraResult

result = await Orchestra.run(
    task="Research AI trends and write a report",
    topology=topology
)

from marsys.coordination.config import ExecutionConfig, StatusConfig

result = await Orchestra.run(
    task="Complex research task",
    topology=topology,
    execution_config=ExecutionConfig(
        convergence_timeout=300.0,
        status=StatusConfig.from_verbosity(1)
    ),
    max_steps=50
)

@classmethod
async def run(
    cls,
    task: Union[str, Dict[str, Any]],
    topology: Union[Dict, Topology, PatternConfig],
    agent_registry: Optional[AgentRegistry] = None,
    context: Optional[Dict[str, Any]] = None,
    execution_config: Optional[ExecutionConfig] = None,
    state_manager: Optional[StateManager] = None,
    max_steps: int = 100,
    allow_follow_ups: bool = False,
    **kwargs
) -> OrchestraResult

task = "Research the latest AI developments"

task = {
    "request": "Analyze market trends",
    "sectors": ["tech", "finance"]
}

task = {
    "content": "What is shown in these images?",
    "images": [
        "/path/to/image1.png",
        "/path/to/image2.jpg"
    ]
}

@dataclass
class OrchestraResult:
    success: bool
    final_response: Any
    branch_results: List[BranchResult]
    total_steps: int
    total_duration: float
    metadata: Dict[str, Any] = field(default_factory=dict)
    error: Optional[str] = None

# Get specific branch result by ID
branch = result.get_branch_by_id("branch_123")

# Get all successful branches
successful = result.get_successful_branches()

# Get final response as formatted text
text = result.get_final_response_as_text()

# Check if response is structured data
is_structured = result.is_structured_response()

result = await Orchestra.run(task, topology)

if result.success:
    print(f"Success in {result.total_duration:.2f}s")
    print(f"Response: {result.get_final_response_as_text()}")

    for branch in result.branch_results:
        print(f"Branch {branch.branch_id}: {branch.status}")
else:
    print(f"Failed: {result.error}")

from marsys.coordination.config import ExecutionConfig, StatusConfig

config = ExecutionConfig(
    convergence_timeout=300.0,  # Overall timeout
    branch_timeout=600.0,       # Per-branch timeout
    step_timeout=120.0,         # Per-step timeout
    dynamic_convergence_enabled=True,
    status=StatusConfig.from_verbosity(1)  # 0=quiet, 1=normal, 2=verbose
)