03 - Agent Streaming

result = await storyteller.stream(client, "Tell me a story about a robot")

# Iterate over text chunks as they arrive
async for chunk in result.text_chunks:
    print(chunk, end="", flush=True)

result = await storyteller.stream(client, "Write a haiku")

async for event in result.events:
    if event.event_type == "text_delta":
        print(event.data.get("content", ""), end="", flush=True)
    elif event.event_type == "tool_call":
        tool_name = event.data.get("tool_call", {}).get("function", {}).get("name")
        print(f"\n[Tool: {tool_name}]")
    elif event.event_type == "agent_finish":
        print("\n[Done]")

result = await storyteller.stream(client, "What are benefits of reading?")

# Wait for completion and get accumulated text
final_text = await result.text()
print(final_text)

git clone https://github.com/polos-dev/polos.git
cd polos/python-examples/03-agent-streaming
cp .env.example .env
uv sync
python worker.py      # Terminal 1
python main.py        # Terminal 2