agent_os_setup.py to start the remote AgentOS instance.
"""
Examples demonstrating AgentOSRunner for remote execution.
Run `agent_os_setup.py` to start the remote AgentOS instance.
"""
import asyncio
from agno.team import RemoteTeam
# ---------------------------------------------------------------------------
# Create Example
# ---------------------------------------------------------------------------
async def remote_agent_example():
"""Call a remote agent hosted on another AgentOS instance."""
# Create a runner that points to a remote agent
team = RemoteTeam(
base_url="http://localhost:7778",
team_id="research-team",
)
response = await team.arun(
"What is the capital of France?",
user_id="user-123",
session_id="session-456",
)
print(response.content)
async def remote_streaming_example():
"""Stream responses from a remote agent."""
team = RemoteTeam(
base_url="http://localhost:7778",
team_id="research-team",
)
async for chunk in team.arun(
"Tell me a 2 sentence horror story",
session_id="session-456",
user_id="user-123",
stream=True,
):
if hasattr(chunk, "content") and chunk.content:
print(chunk.content, end="", flush=True)
async def main():
"""Run all examples in a single event loop."""
print("=" * 60)
print("RemoteTeam Examples")
print("=" * 60)
# Run examples
# Note: Remote examples require a running AgentOS instance
print("\n1. Remote Team Example:")
await remote_agent_example()
print("\n2. Remote Streaming Example:")
await remote_streaming_example()
# ---------------------------------------------------------------------------
# Run Example
# ---------------------------------------------------------------------------
if __name__ == "__main__":
asyncio.run(main())
Run the Example
# Clone and setup repo
git clone https://github.com/agno-agi/agno.git
cd agno/cookbook/05_agent_os/remote
# Create and activate virtual environment
./scripts/demo_setup.sh
source .venvs/demo/bin/activate
python 02_remote_team.py