Python SDK / 02 — Connectors

02 — Connectors

Wire MCP servers, registry experts, and other Corti agents into an orchestrator agent using the connectors factory.

Connector types

Full code

"""
02 — Connectors.

Build an orchestrator that routes to a sub-agent and a registry expert.
"""
import asyncio, os
from corti_agent_sdk import CortiClient, AgentsClient, connectors

async def main():
    async with CortiClient(
        tenant_name="YOUR_TENANT",
        environment="eu",
        auth={"client_id": "YOUR_ID", "client_secret": "YOUR_SECRET"},
    ) as client:
        agents = AgentsClient(client)

        # 1 — Create a specialised sub-agent
        symptom_agent = await agents.create(
            name="symptom-extractor",
            description="Extracts structured symptoms from a clinical note.",
            system_prompt="Return a JSON array of symptoms. No prose.",
        )

        # 2 — Create an orchestrator with multiple connectors
        orchestrator = await agents.create(
            name="orchestrator",
            description="Routes clinical queries to the right expert.",
            system_prompt="You coordinate medical coding. Use your experts.",
            connectors=[
                connectors.from_agent(symptom_agent.id),
                connectors.registry(name="@corti/medical-coding"),
                # Attach an optional MCP server:
                # connectors.mcp(mcp_url="https://mcp.corti.ai", auth_type="inherit"),
            ],
        )

        ctx = orchestrator.create_context()
        # Raise timeout for orchestrators that fan out to several sub-agents.
        reply = await ctx.send_text(
            "Patient has chest pain and shortness of breath. What ICD-10 codes apply?",
            timeout_in_seconds=180,
        )
        print(reply.text)

asyncio.run(main())

Next steps