2.1 KiB
Changelog
Unreleased
Added
-
Thread-centric streaming (v3) —
client.threads.stream()returns anAsyncThreadStream(orSyncThreadStream) context manager that owns one SSE or WebSocket connection for the lifetime of a thread session. -
Typed projections —
thread.messages,thread.tool_calls,thread.values, andthread.extensions[name]all share the same underlying transport connection. Iterating multiple projections concurrently expands the server-side filter union without opening additional connections. -
Scoped subgraph handles —
thread.subgraphs(aliasthread.subagents) yields oneScopedStreamHandleper direct child invocation, each exposing.messages,.tool_calls, and.subgraphsscoped to that namespace. -
WebSocket transport — pass
transport="websocket"toclient.threads.stream()to use a WebSocket connection instead of SSE (async client only). -
Automatic reconnect — the shared SSE fan-out and the lifecycle watcher both reconnect on transport drops, replaying missed events via a
sincecursor and deduplicating byevent_id. -
thread.agent.get_tree()— fetches the assistant graph definition for the current session'sassistant_idwith optionalxraydepth control. -
thread.run.respond()— resumes a run after a server-side interrupt, resolving the outstandingInterruptPayloadbyinterrupt_id. -
thread.output— awaitable that resolves to the terminal thread statevaluesdict after the run lifecycle completes.
Changed
client.threads.stream()now acceptstransport="sse"(default) ortransport="websocket"in place of the previous transport-agnostic default.
Notes
- The v3 streaming surface (
AsyncThreadStream,SyncThreadStream, and all projection classes) is new in this release. The existingclient.runs.stream()(v2) surface is unchanged and remains fully supported. thread_idis minted client-side (UUIDv4) when not provided; the server creates the thread row lazily on the firstrun.start.