Tool Execution Streaming
Benchmarked against: Anthropic — Fine-grained Tool Streaming Status: Partial implementation — real-time feedback via heartbeat and factory floor Scope: How agents report tool execution progress in real-time
SuperPortia provides real-time visibility into agent operations through heartbeat, factory floor status, and work order state transitions — not traditional SSE/WebSocket streaming.
Real-time feedback model
Unlike traditional API streaming (where tokens stream as they're generated), SuperPortia's "streaming" is operational visibility:
Heartbeat streaming
Agents send periodic heartbeats to register as online:
agent_heartbeat()
What heartbeat reports
| Field | Description | Update frequency |
|---|---|---|
agent_id | Agent identity | Every heartbeat |
ship | Ship identifier | Every heartbeat |
status | online / offline | Every heartbeat |
current_task | What the agent is doing | When task changes |
last_seen | Last heartbeat timestamp | Every heartbeat |
Work order state streaming
Work orders provide granular progress tracking through state transitions:
Each transition is logged with:
| Field | Description |
|---|---|
from_status | Previous state |
to_status | New state |
changed_by | Who made the change |
timestamp | When it happened |
notes | Context for the transition |
completion_summary | What was done (for review transitions) |
actual_hours | Time spent (for review transitions) |
Factory floor status
The factory floor provides a real-time dashboard of all operations:
factory_floor_status()
What it shows
| Section | Content |
|---|---|
| Team status | Each agent's online/offline status and current task |
| Active WOs | Work orders currently in_progress |
| Awaiting review | WOs pending Captain approval |
| Blocked items | WOs with blockers |
| Recent completions | Recently approved WOs |
| Service health | System services status |
Agent messaging as streaming
Inter-agent communication provides another feedback channel:
send_agent_message(
to="夏哥",
subject="WO-2026-0305-001 Progress",
body="Step 3 of 5 complete. Running tests now."
)
| Feature | Usage |
|---|---|
| Direct messages | Agent-to-agent or agent-to-Captain |
| Priority levels | normal or urgent |
| Mailbox persistence | Messages survive across sessions |
| Read/unread tracking | Know which messages have been seen |
Comparison with traditional streaming
| Feature | Traditional API streaming | SuperPortia operational streaming |
|---|---|---|
| Granularity | Token-by-token | Task-by-task |
| Protocol | SSE / WebSocket | MCP tool calls |
| Latency | Milliseconds | Seconds to minutes |
| Use case | Chat UX | Operations monitoring |
| Persistence | Ephemeral | Logged in UB / WO system |
Future directions
| Enhancement | Description | Status |
|---|---|---|
| Bridge real-time tab | WebSocket-based live dashboard | Planned |
| WO progress percentage | Granular progress within a WO | Under evaluation |
| Event bus | Cross-agent event streaming | Under evaluation |
| Webhook notifications | External system integration | Under evaluation |
Related pages
| Page | Relationship |
|---|---|
| Real-time Status | Heartbeat and factory floor |
| WO Lifecycle | Work order state machine |
| Tool Discovery | Available tools |