Connect MCP tools

import asyncio
import os

from air import Worker


async def main() -> None:
    worker = Worker(
        os.environ["AIR_BASE_URL"],
        os.environ["AIR_WORKER_KEY"],
        environment=os.getenv("AIR_WORKER_ENV", "staging"),
    )
    stop = asyncio.Event()
    try:
        names = await worker.mount_mcp(
            "stdio",
            command=["python", "my_mcp_server.py"],
            prefix="inventory",
        )
        print("registered", names)
        await worker.run(stop)
    finally:
        await worker.aclose()


asyncio.run(main())

names = await worker.mount_mcp(
    "http",
    url="http://127.0.0.1:8765/mcp",
    prefix="internal",
    timeout=30,
)