RemoteAgent

pip install agno

from agno.agent import RemoteAgent

# Create a remote agent pointing to a remote AgentOS instance
agent = RemoteAgent(
    base_url="http://localhost:7777",
    agent_id="my-agent",
)

# Run the agent (async)
response = await agent.arun("What is the capital of France?")
print(response.content)

print(agent.id)  # "my-agent"

print(agent.name)  # "My Agent"

print(agent.description)  # "A helpful assistant agent"

print(agent.role)  # "assistant"

tools = agent.tools
if tools:
    for tool in tools:
        print(tool["name"])

if agent.db:
    print(f"Database ID: {agent.db.id}")

if agent.knowledge:
    print("Agent has knowledge enabled")

# Non-streaming
response = await agent.arun(
    "Tell me about Python",
    user_id="user-123",
    session_id="session-456",
)
print(response.content)

# Streaming
async for event in agent.arun(
    "Tell me a story",
    stream=True,
    user_id="user-123",
):
    if hasattr(event, "content") and event.content:
        print(event.content, end="", flush=True)

from agno.models.response import ToolExecution

response = await agent.acontinue_run(
    run_id="run-123",
    updated_tools=[
        ToolExecution(
            tool_call_id="call-1",
            result="Tool result here",
        )
    ],
)

success = await agent.cancel_run(run_id="run-123")
if success:
    print("Run cancelled")

config = await agent.get_agent_config()
print(f"Agent name: {config.name}")
print(f"Model: {config.model}")

config = agent.refresh_config()

from agno.agent import RemoteAgent
from agno.team import Team
from agno.models.openai import OpenAIChat

# Remote agent from another AgentOS instance
researcher = RemoteAgent(
    base_url="http://research-server:7777",
    agent_id="researcher-agent",
)

# Local team with remote agent member
team = Team(
    name="Research Team",
    model=OpenAIChat(id="gpt-4o"),
    members=[researcher],
    instructions="Coordinate research tasks",
)

response = await team.arun("Research AI trends")

from agno.agent import RemoteAgent
from agno.os import AgentOS

agent_os = AgentOS(
    agents=[
        RemoteAgent(base_url="http://server-1:7777", agent_id="agent-1"),
        RemoteAgent(base_url="http://server-2:7777", agent_id="agent-2"),
    ],
)

from agno.exceptions import RemoteServerUnavailableError

try:
    response = await agent.arun("Hello")
except RemoteServerUnavailableError as e:
    print(f"Remote server unavailable: {e.message}")

response = await agent.arun(
    "Hello",
    auth_token="your-jwt-token",
)