Added server-side streams to the Python SDK. - #1

Closed

moedash wants to merge 43 commits into

moe/AI-198-streams-interfacefrom

moe/AI-198-stream-client

Commits on Sep 21, 2026

Pinned Core to the stream revision and regenerated bridge protos.
moedash
committed
9343163
Added the vendored stream API protos.
moedash
committed
b4a5c9a
Added the stream client and the workflow stream surface.
moedash
committed
ac3ff22
Added the Workflow Streams surface over a server-side stream.
moedash
committed
42589d8
Added the native provider module.
moedash
committed
303461b
Made cursors exclusive, added latest(), and allowed topic appends.
moedash
committed
372974d
Read the delivered message shape the buffer now hands back.
moedash
committed
bb21548
Regenerated the protos from the pinned Core.
moedash
committed
87f6006
Sorted and formatted the server-side stream modules.
moedash
committed
d4fe1c8
Made the server-side stream modules pass the type and doc linters.
moedash
committed
7a0eda3
Added the changelog entry for server-side streams.
moedash
committed
facbf71
Regenerated the vendored stream protos for protobuf 3.
moedash
committed
014c37c
Repinned Core to the finalized replay-slice branch.
moedash
committed
96f8b6c
Qualified the LangGraph docstring's stream references.
moedash
committed
aee2eb3
Repinned Core to the WIT-aligned replay-slice head.
moedash
committed
eb3f3f8
Regenerated the bridge protos from the repinned Core.
moedash
committed
23138d9
Adapted the native provider to the interface changes.
moedash
committed
bf7039e
Pinned native stream handles to a run and closed their channels.
moedash
committed
07755d9
Stopped the flusher without cancelling it and pinned the contrib client.
moedash
committed
d8c2efd
Checked stream ranges for continuity and mirrored the byte limits.
moedash
committed
aa803f2
Corrected the subscribe docstring and two stale test comments.
moedash
committed
a6eedbc
Repinned Core to the reviewed moe/AI-198-fix-replay-slice-lookahead head.
moedash
committed
aa5f2c0
Regenerated the bridge protos from the repinned Core.
moedash
committed
200a5c6
Repinned Core to the reviewed replay-slice head.
moedash
committed
837404c
Regenerated the bridge protos from the repinned Core.
moedash
committed
6deaad6
Regenerated the vendored stream service protos from the record server.
moedash
committed
f734908
Moved the workflow stream runtime to records and batched a task's publishes.
moedash
committed
0bbf54b
Moved the stream client and the contrib surface to records and SDK errors.
moedash
committed
3d22dc5
Rewrote the native provider with one owned stream per topic.
moedash
committed
d3243e9
Opened the native tests' handles through client.get_stream_handle.
moedash
committed
45bd0ab
Took topic definitions on the native handle.
moedash
committed
d5e8f4b
Let a pushed history carry stream slices and repinned Core.
moedash
committed
ebba767
Tested a payload codec on both halves of the native provider.
moedash
committed
4f9fa21
Fetched a consuming workflow's stream records for the Replayer.
moedash
committed
e5d1e20
Repinned Core so a task owed records it was not sent fails first.
moedash
committed
dcab142
Followed a workflow reset on the native handle.
moedash
committed
5c46cec
Fetched each era of a reset run's history from the run that holds it.
moedash
committed
fe80330
Repinned Core so a sticky legacy query owed records goes unanswered.
moedash
committed
437be0c
Tested queries and a reset against the native provider.
moedash
committed
43504a8