Sub-Agent Delegation Example

import requests
import os
import json

API_BASE_URL = "https://api.swarms.world"
API_KEY = os.environ.get("SWARMS_API_KEY", "your_api_key_here")

headers = {
    "x-api-key": API_KEY,
    "Content-Type": "application/json"
}

def analyze_market(company: str) -> dict:
    """Run a parallel market analysis using sub-agent delegation."""

    payload = {
        "agent_config": {
            "agent_name": "Market-Analysis-Coordinator",
            "description": "Senior market analyst that coordinates parallel research streams",
            "system_prompt": (
                "You are a senior market analyst coordinating a research team. "
                "For each analysis request:\n"
                "1. Create specialized sub-agents for each research domain\n"
                "2. Assign specific research tasks to each sub-agent\n"
                "3. Wait for all results and compile a comprehensive market report\n\n"
                "Always create at least 3 sub-agents covering: "
                "financial analysis, competitive landscape, and industry trends."
            ),
            "model_name": "gpt-4.1",
            "max_loops": "auto",
            "max_tokens": 8192,
            "temperature": 0.3
        },
        "task": (
            f"Conduct a comprehensive market analysis for {company}. "
            "Create specialized sub-agents and delegate the following research areas:\n"
            "1. Financial Analysis: Revenue trends, profitability, key financial metrics\n"
            "2. Competitive Landscape: Major competitors, market share, differentiation\n"
            "3. Industry Trends: Market growth, emerging technologies, regulatory changes\n"
            "4. Risk Assessment: Key risks, vulnerabilities, mitigation strategies\n\n"
            "Compile all findings into a structured executive briefing."
        )
    }

    response = requests.post(
        f"{API_BASE_URL}/v1/agent/completions",
        headers=headers,
        json=payload,
        timeout=300
    )

    return response.json()

result = analyze_market("Tesla Inc.")

if result.get("success"):
    print(f"Agent: {result['name']}")
    print(f"Output:\n{result['outputs'][:2000]}...")
else:
    print(f"Error: {result}")