Repository navigation

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

Closed

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

Commits

Commits on Sep 21, 2026

Commits on Sep 22, 2026