Getting Started with MARSYS

from marsys.agents import Agent
from marsys.models import ModelConfig

# Create agents with same configuration
model_config = ModelConfig(
    type="api",
    name="anthropic/claude-sonnet-4.5",
    provider="openrouter"
)

# Define agents and their allowed interactions
researcher = Agent(
    model_config=model_config,
    name="Researcher",
    goal="Expert at finding and analyzing information",
    instruction="You are a research specialist. Find and analyze information thoroughly.",
    allowed_peers=["Writer"]  # Can invoke the Writer agent
)

writer = Agent(
    model_config=model_config,
    name="Writer",
    goal="Skilled at creating clear, engaging content",
    instruction="You are a skilled writer. Create clear, engaging content based on research.",
    allowed_peers=[]  # Cannot invoke other agents
)

# Run with automatic topology creation
result = await researcher.auto_run(
    task="Research AI trends and write a report",
    max_steps=20,
    verbosity=1  # Show progress
)

print(result)

# One-line execution for simple tasks
result = await Orchestra.run(
    task="Analyze this data",
    topology={"agents": ["Analyst"], "flows": []}
)

# Choose from 8 pre-defined patterns
topology = PatternConfig.pipeline(
    stages=[
        {"name": "collect", "agents": ["Collector"]},
        {"name": "process", "agents": ["Processor1", "Processor2"]},
        {"name": "report", "agents": ["Reporter"]}
    ],
    parallel_within_stage=True
)

# True parallel execution with isolated agents
pool = AgentPool(
    agent_class=BrowserAgent,
    num_instances=3,
    name="BrowserPool"
)

# Long-running workflows with checkpoints
result = await Orchestra.run(
    task="Multi-day research project",
    topology=topology,
    state_manager=StateManager(storage)
)

import asyncio
from marsys.coordination import Orchestra
from marsys.agents import Agent
from marsys.models import ModelConfig

# Create a single model configuration
model_config = ModelConfig(
    type="api",
    name="anthropic/claude-sonnet-4.5",
    provider="openrouter"
)

# Create specialized agents
researcher = Agent(
    model_config=model_config,
    name="Researcher",
    goal="Expert at finding and analyzing information",
    instruction="You are a research specialist. Find and analyze information thoroughly."
)

writer = Agent(
    model_config=model_config,
    name="Writer",
    goal="Skilled at creating clear, engaging content",
    instruction="You are a skilled writer. Create clear, engaging content based on research."
)

# Define workflow
topology = {
    "agents": ["Researcher", "Writer"],
    "flows": ["Researcher -> Writer"]
}

# Run the system
async def main():
    result = await Orchestra.run(
        task="Research quantum computing and write a beginner's guide",
        topology=topology
    )
    print(result.final_response)

asyncio.run(main())