Repository navigation

[Brook] Moved Streams to temporalio.common with the reviewed API. - #365

Closed

moetemp wants to merge 45 commits into

moe/brook/v4/p34-client-objectsfrom

moe/brook/v5/p35-reviewed-api

Closed

[Brook] Moved Streams to temporalio.common with the reviewed API.#365
moetemp wants to merge 45 commits into
moe/brook/v4/p34-client-objectsfrom
moe/brook/v5/p35-reviewed-api

Commits on Oct 24, 2026
- Turned temporalio.common into a package.
  moetemp
  committed
  95c6553
- Moved the Streams package to temporalio.common.streams.
  moetemp
  committed
  8e0d7ce
- Removed auto_close, close_with_run and the run-end close on Redis.
  moetemp
  committed
  e55fb79
- Removed the Worker eviction hook and the plugin shutdown wait.
  moetemp
  committed
  0aa2dd8
- Registered Stream backends on the client, and added the entry points.
  moetemp
  committed
  8aaff83
- Renamed the read options to offset and topic_prefixes.
  moetemp
  committed
  5eb5bce
- Vendored the s23 Stream protos and WIT, and regenerated the bindings.
  moetemp
  committed
  4d67eec
- Pinned the streams crate to s23 and sdk-core to c8.
  moetemp
  committed
  602b1b6
- Closed a Workflow Stream with an Activity committed with its task.
  moetemp
  committed
  a66eab7
- Tried a failed first-run lookup of a Workflow's Stream again.
  moetemp
  committed
  c9323c1
- Tightened the Stream backend registration.
  moetemp
  committed
  e7271cd
- Corrected the Workflow Stream docs on backends and on init.
  moetemp
  committed
  df4c0d9
- Put the Workflow close behind a backend method.
  moetemp
  committed
  74b759c
- Noted in the Redis package docs that Workers poll the close Activity.
  moetemp
  committed
  0a8927f
Commits on Oct 25, 2026
- Decoded the Stream test vectors as UTF-8 on every OS.
  moetemp
  committed
  e771693
- Took a client config with no interceptors in the Stream backends.
  moetemp
  committed
  b880a6d
- Hid the generated Stream Nexus clients from the API docs.
  moetemp
  committed
  3ef573b
- fix: annotate pydantic TypeAdapter cache for pydantic 2.14 (#2011)
  
  jmaeagle99
  authored and
  moetemp
  committed
  c3b3798
- Added a changelog fragment for Streams.
  moetemp
  committed
  e033b82
- Hid only the generated Stream clients from the API docs.
  moetemp
  committed
  71ae539
- Named the Stream entry points and other API changes in the changelog.
  moetemp
  committed
  da1da37
- Refused a Local Activity's close of a Workflow's Stream.
  moetemp
  committed
  3fe0dfa
- Closed a Workflow's Stream as canceled when a cancel ends its block.
  moetemp
  committed
  85894c5
- Settled a deferred block-end close from the run's real outcome.
  moetemp
  committed
  4959553
- Kept a no-wait read going while an empty page moves on.
  moetemp
  committed
  76e918c
- Let an Activity retry go on with a closed or expired Stream argument.
  moetemp
  committed
  8382d32
- Decoded a Closed item's failure with the reader's converter.
  moetemp
  committed
  802b7a4
- Wrote a transfer type dataclass in a top-level list as its fields.
  moetemp
  committed
  3885277
- Bounded the pending Workflow appends by bytes and dropped refused ones.
  moetemp
  committed
  0d39c78
- Warned when a Worker with Streams polls no Activities.
  moetemp
  committed
  a488efe
- Raised StreamExpiredError at the create of an expired Stream.
  moetemp
  committed
  0c173b5
- Raised a StreamError past a Record that fails to decode.
  moetemp
  committed
  2e47ec1
- Refused async with on a client handle of a Workflow's Stream.
  moetemp
  committed
  8358aef
- Refused an empty Stream id at Client.stream.
  moetemp
  committed
  0cd056c
- Kept no offsets of client Records in a read.
  moetemp
  committed
  1de5999
- Exported End and dropped the unused RPC error mapping.
  moetemp
  committed
  6c60f97
- Keyed a Workflow's Activities only when its run uses Streams.
  moetemp
  committed
  c0da527
- Corrected the Retention, aclose and Stream error docstrings.
  moetemp
  committed
  d06cba4
- Narrowed the item and failure types in the new Stream tests.
  moetemp
  committed
  68bb7b7
- Added StreamTooLargeError for the reason stream_too_large.
  moetemp
  committed
  2ef3bcf
- Pinned crate s23 ee6d1e51 and Core c8 f7826366.
  moetemp
  committed
  2e2ffe5
- Moved the Streams API into `temporalio.common`.
  moetemp
  committed
  2ff42e1
- Tightened the comments and docs on this branch.
  moetemp
  committed
  b4c5cee
- Dropped the figurative wording from three Stream error messages.
  moetemp
  committed
  8f71f3e
- Made WorkflowTopic.publish start the write and return its future.
  moetemp
  committed
  415fb36

Commits

Commits on Oct 24, 2026

Commits on Oct 25, 2026