Google ADK agents and Dome

import asyncio
 
from google.adk.agents import LlmAgent
from google.adk.models.lite_llm import LiteLlm
from google.adk.runners import InMemoryRunner
from google.adk.tools.mcp_tool import McpToolset, StreamableHTTPConnectionParams
from google.genai import types
 
researcher = LlmAgent(
    name="researcher",
    instruction="Answer questions about the code. Search before you answer.",
    # Model: a pool on the Broker, through the OpenAI-compatible endpoint
    model=LiteLlm(
        model="openai/claude-opus-5-5",
        api_base=f"{GATEWAY_URL}/v1",
        api_key=DOME_AGENT_KEY,
    ),
    # Tools: whatever this agent is granted on the Gateway
    tools=[McpToolset(connection_params=StreamableHTTPConnectionParams(
        url=f"{GATEWAY_URL}/mcp",
        headers={"Authorization": f"Bearer {DOME_AGENT_KEY}"},
    ))],
)
 
 
async def main():
    runner = InMemoryRunner(agent=researcher, app_name="researcher")
    session = await runner.session_service.create_session(app_name="researcher", user_id="k.brandt")
    question = types.Content(role="user", parts=[types.Part(text="Where is rate limiting handled?")])
    async for event in runner.run_async(user_id="k.brandt", session_id=session.id, new_message=question):
        if event.is_final_response() and event.content:
            print(event.content.parts[0].text)
 
 
asyncio.run(main())