Repository navigation

feat: add `take`, `filter` and `reduce` to a Stream, and a pipeline on top - #2131

Draft

moetemp wants to merge 31 commits into

moe/streams-apifrom

moe/streams-workflow-read

Draft

feat: add `take`, `filter` and `reduce` to a Stream, and a pipeline on top#2131
moetemp wants to merge 31 commits into
moe/streams-apifrom
moe/streams-workflow-read

Commits on Nov 14, 2026
- Added a Workflow read of a Stream that waits for a predicate.
  moetemp
  committed
  0bf0f0a
- Filled in the Records of a Workflow read before a replay.
  moetemp
  committed
  a5d9ad6
- Tested and measured the Workflow read.
  moetemp
  committed
  f216560
- Gave the Workflow read a stop reason and added a fold over its Records.
  moetemp
  committed
  609c292
- Fitted the Workflow read to the Workflow append and close.
  moetemp
  committed
  b2b9a5f
- Pointed the refused Workflow read at `workflow.read_stream`.
  moetemp
  committed
  cdf7cc5
- Failed the Workflow for a read with no Stream config.
  moetemp
  committed
  b4cac1d
- Replaced the Workflow read with take, filter and reduce calls.
  moetemp
  committed
  c360a9a
- Let BufferedAppender write inside the function of a Stream call.
  moetemp
  committed
  9b03851
- Tested the Stream calls in Workflow, client and Activity code.
  moetemp
  committed
  45aa145
- Fixed the type and docstring findings of the Stream calls.
  moetemp
  committed
  19569c7
- Fitted the Stream calls to the move of BufferedAppender.
  moetemp
  committed
  b1cf57d
- Moved Core to the Stream WIT with take, filter and reduce.
  moetemp
  committed
  d7564a7
- Pinned the Stream generator to the nexgen build with helper methods.
  moetemp
  committed
  b1a61aa
- Regenerated the Streams API with take, filter and reduce.
  moetemp
  committed
  4716779
- Wired the generated take, filter and reduce to the support helpers.
  moetemp
  committed
  f81fa77
- Added a pipeline that runs a chain of Stream steps as one call.
  moetemp
  committed
  116f765
- Kept the Records of take and filter out of History when a Worker asks.
  moetemp
  committed
  e68591a
- Tested where a replay of a take or a filter gets its Records.
  moetemp
  committed
  66019c8
- Fixed the API docs build for the replay setting.
  moetemp
  committed
  2de2f0a
- Wrapped four docstring lines that were over 100 characters.
  moetemp
  committed
  e5c8a33
- Moved Core to the Stream WIT with the method guard.
  moetemp
  committed
  3f8a301
- Pinned the Stream generator to the nexgen build with `@nexus.guard`.
  moetemp
  committed
  d842202
- Added a check of where code calls a Stream method.
  moetemp
  committed
  4e431f5
- Regenerated the Stream classes with the method guard.
  moetemp
  committed
  703fdd8
- Tested that a Stream refuses a call from the wrong place.
  moetemp
  committed
  d749c81
Commits on Nov 15, 2026

Navigation Menu

Repository navigation

feat: add `take`, `filter` and `reduce` to a Stream, and a pipeline on top - #2131

feat: add `take`, `filter` and `reduce` to a Stream, and a pipeline on top#2131
moetemp wants to merge 31 commits into
moe/streams-apifrom
moe/streams-workflow-read

Commits on Nov 14, 2026

Added a Workflow read of a Stream that waits for a predicate.

Filled in the Records of a Workflow read before a replay.

Tested and measured the Workflow read.

Gave the Workflow read a stop reason and added a fold over its Records.

Fitted the Workflow read to the Workflow append and close.

Pointed the refused Workflow read at `workflow.read_stream`.

Failed the Workflow for a read with no Stream config.

Replaced the Workflow read with take, filter and reduce calls.

Let BufferedAppender write inside the function of a Stream call.

Tested the Stream calls in Workflow, client and Activity code.

Fixed the type and docstring findings of the Stream calls.

Fitted the Stream calls to the move of BufferedAppender.

Moved Core to the Stream WIT with take, filter and reduce.

Pinned the Stream generator to the nexgen build with helper methods.

Regenerated the Streams API with take, filter and reduce.

Wired the generated take, filter and reduce to the support helpers.

Added a pipeline that runs a chain of Stream steps as one call.

Kept the Records of take and filter out of History when a Worker asks.

Tested where a replay of a take or a filter gets its Records.

Fixed the API docs build for the replay setting.

Wrapped four docstring lines that were over 100 characters.

Moved Core to the Stream WIT with the method guard.

Pinned the Stream generator to the nexgen build with `@nexus.guard`.

Added a check of where code calls a Stream method.

Regenerated the Stream classes with the method guard.

Tested that a Stream refuses a call from the wrong place.

Commits on Nov 15, 2026

Added a pipeline end that appends its items to another Stream.

Tested the pipeline end that appends to another Stream.

Tested a generator over `take` that reads a running Activity's Stream.

Made the Store the default replay source of a Workflow read.

Tested the Stream reads under the new default replay source.