from veadk import Agent
from google.adk.tools.mcp_tool.mcp_toolset import MCPToolset
from google.adk.tools.mcp_tool.mcp_session_manager import (
StreamableHTTPConnectionParams,
)
toolset = MCPToolset(
connection_params=StreamableHTTPConnectionParams(
url="https://your-mcp-endpoint",
headers={"Authorization": "Bearer your-api-key-here"},
),
)
agent = Agent(tools=[toolset])