pip install agentic-fleet python-dotenv fastapi uvicorn

# config.py
from agentic_fleet.core.config import Config

config = Config.from_env()

from agentic_fleet.agent import CodeAssistant
from agentic_fleet.agent.specialized.code import (
    ArchitectAgent,
    DeveloperAgent,
    ReviewerAgent,
    TesterAgent
)

# System Architect
architect = ArchitectAgent(
    role="architect",
    capabilities=["design", "planning"],
    config={
        "model": "gpt-4",
        "temperature": 0.7
    }
)

# Developer
developer = DeveloperAgent(
    role="developer",
    capabilities=["coding", "debugging"],
    config={
        "model": "gpt-4",
        "temperature": 0.2
    }
)

# Code Reviewer
reviewer = ReviewerAgent(
    role="reviewer",
    capabilities=["review", "best_practices"],
    config={
        "model": "gpt-4",
        "temperature": 0.3
    }
)

# Tester
tester = TesterAgent(
    role="tester",
    capabilities=["testing", "quality"],
    config={
        "model": "gpt-4",
        "temperature": 0.2
    }
)

from agentic_fleet import FleetChat
from agentic_fleet.fleets.coordination import CoordinationPattern

fleet = FleetChat(
    name="api_development",
    agents={
        "architect": architect,
        "developer": developer,
        "reviewer": reviewer,
        "tester": tester
    },
    coordination_pattern=CoordinationPattern.SEQUENTIAL,
    coordination_config={
        "sequence": [
            "architect",
            "developer",
            "reviewer",
            "tester"
        ]
    }
)

response = await fleet.initiate_chat(
    initiator_id="architect",
    message="""
    Design a REST API for a task management system with:
    - User authentication
    - Task CRUD operations
    - Task assignment
    - Status updates
    """
)

# Developer receives the design and implements
response = await fleet.send_message(
    "Here's the FastAPI implementation based on the design..."
)

# Reviewer checks code quality
response = await fleet.send_message(
    "Reviewing the implementation for best practices..."
)

# Tester creates test cases
response = await fleet.send_message(
    "Creating test suite for the API endpoints..."
)

import asyncio
from agentic_fleet import FleetChat
from agentic_fleet.agent.specialized.code import *

async def develop_api():
    # Create agents
    agents = {
        "architect": ArchitectAgent(role="architect"),
        "developer": DeveloperAgent(role="developer"),
        "reviewer": ReviewerAgent(role="reviewer"),
        "tester": TesterAgent(role="tester")
    }
    
    # Create fleet
    fleet = FleetChat(
        name="api_development",
        agents=agents,
        coordination_pattern=CoordinationPattern.SEQUENTIAL,
        coordination_config={
            "sequence": [
                "architect",
                "developer",
                "reviewer",
                "tester"
            ]
        }
    )
    
    # Start development
    response = await fleet.initiate_chat(
        initiator_id="architect",
        message="Design a task management API"
    )
    
    # Development continues automatically through the sequence
    while not fleet.is_complete():
        await asyncio.sleep(1)
    
    return fleet.get_artifacts()

# Run development
artifacts = asyncio.run(develop_api())