MCP

Connect to any MCP (Model Context Protocol) server. The provider wraps the server’s tools in a sub-agent, exposing them as query_mcp_<name>.

from agno.agent import Agent
from agno.context.mcp import MCPContextProvider

github = MCPContextProvider(
    server_name="github",
    transport="stdio",
    command="npx",
    args=["-y", "@modelcontextprotocol/server-github"],
)

await github.asetup()

agent = Agent(
    model=...,
    tools=github.get_tools(),
)

await agent.arun("List my recent pull requests")
await github.aclose()

MCPContextProvider is read-only by default. The tool name includes the server name: query_mcp_github.

Transport Options

stdio
sse
streamable-http

Run a local process.

mcp = MCPContextProvider(
    server_name="github",
    transport="stdio",
    command="npx",
    args=["-y", "@modelcontextprotocol/server-github"],
)

Connect to an SSE endpoint.

mcp = MCPContextProvider(
    server_name="my-server",
    transport="sse",
    url="http://localhost:8080/sse",
)

Connect to an HTTP endpoint with streaming.

mcp = MCPContextProvider(
    server_name="my-server",
    transport="streamable-http",
    url="http://localhost:8080/mcp",
    headers={"Authorization": "Bearer ..."},
)

Configuration

Parameter	Type	Default	Description
`server_name`	`str`	required	Name of the MCP server. Used in tool name.
`transport`	`str`	required	`"stdio"`, `"sse"`, or `"streamable-http"`.
`command`	`str`	`None`	Command to run (stdio transport).
`args`	`list[str]`	`None`	Command arguments (stdio transport).
`url`	`str`	`None`	Server URL (sse/http transports).
`headers`	`dict`	`None`	HTTP headers (sse/http transports).
`env`	`dict`	`None`	Environment variables for the subprocess.
`timeout_seconds`	`int`	`30`	Connection timeout.
`id`	`str`	`"mcp_<name>"`	Tool becomes `query_<id>`.
`model`	`Model`	`None`	Model for the sub-agent.

Tools Exposed

Tool	Description
`query_mcp_<name>`	Query the MCP server. Sub-agent calls the server’s tools internally.

Lifecycle Management

MCPContextProvider requires explicit setup and teardown:

mcp = MCPContextProvider(...)

await mcp.asetup()   # Connect to server
try:
    # Use the provider
    agent = Agent(model=..., tools=mcp.get_tools())
    await agent.arun("...")
finally:
    await mcp.aclose()  # Disconnect

Transport Options

Configuration

Tools Exposed

Lifecycle Management

Resources

MCPTools Reference

MCP Servers

​Transport Options

​Configuration

​Tools Exposed

​Lifecycle Management

​Resources

MCPTools Reference

MCP Servers

Transport Options

Configuration

Tools Exposed

Lifecycle Management

Resources