Repository navigation

Added the stream examples, one per path and one composed. - #7

Closed

moetemp wants to merge 1260 commits into

moe/AI-198-st-py-unionfrom

moe/AI-198-streams-examples

This pull request is big! We're only showing the most recent 250 commits

Commits on Oct 2, 2026
Commits on Oct 3, 2026
Commits on Oct 5, 2026
- Pinned Core at the external runtime's channel wake.
  moetemp
  committed
  e6898c5
- Listed the external-stream fixes the Core pin brings in.
  moetemp
  committed
  bbb4aaf
- Move sdk-core submodule to 6e90e6d5 and fix bridge build
  
  authored and
  moetemp
  committed
  2c40524
- External streams: generated protos, record model, and the Redis fixture
  
  authored and
  moetemp
  committed
  d8dbfdd
- External streams: backend contract, annotation codec, codec, failure taxonomy
  
  authored and
  moetemp
  committed
  bcc67e6
- External streams: parking contract, Redis provider, registry, producer, bridge
  
  authored and
  moetemp
  committed
  a6b44bc
- External streams: subscription manager and the Workflow-facing API
  
  authored and
  moetemp
  committed
  1d4b22e
- External streams: wire the feature into the Python Worker
  
  authored and
  moetemp
  committed
  0615ea9
- P13: the replay read path
  
  authored and
  moetemp
  committed
  aadf012
- P14: the producer wake-signal path
  
  authored and
  moetemp
  committed
  ea590b0
- P6b: publish()'s acknowledged-wake semantics
  
  authored and
  moetemp
  committed
  301af4d
- P15: the Continue-As-New cursor
  
  authored and
  moetemp
  committed
  a6507e9
- P21: multiple streams, merge, and same-stream subscriptions
  
  authored and
  moetemp
  committed
  4d0aea7
- P20: the Worker shutdown wake sweep
  
  authored and
  moetemp
  committed
  8c12e9f
- P16b: the Milestone 2 required-test list
  
  authored and
  moetemp
  committed
  bd8840b
- Fix the failure-taxonomy row for an annotation mismatch, and P20's missing retry
  
  authored and
  moetemp
  committed
  5fdab62
- P16a/P16b: make the milestone gates enforceable
  
  authored and
  moetemp
  committed
  d0bad85
- Core bump for C8/C10, and three more Milestone 1 cases
  
  authored and
  moetemp
  committed
  7e0bf4a
- Replay a stream history through the real Replayer
  
  authored and
  moetemp
  committed
  e0b7957
- Deliver a record buffered while Workflow code was elsewhere
  
  authored and
  moetemp
  committed
  892e549
- Core bump for C15b, and correct a replay finding made against a stale bridge
  
  authored and
  moetemp
  committed
  4ad9809
- The livelock does not exist: fix the test helper that caused it
  
  authored and
  moetemp
  committed
  9f53650
- Bound delivery within one activation (ADR-026)
  
  authored and
  moetemp
  committed
  74e5fc3
- Fix four defects the required-test list exposed
  
  authored and
  moetemp
  committed
  72d467d
- Make an unparked wake's sender identity unique per sender
  
  authored and
  moetemp
  committed
  f87e790
- Rollover cases: one test defect fixed, two reasons corrected
  
  authored and
  moetemp
  committed
  3ee3d05
- Rollover cases 19 and 23: both were test defects
  
  authored and
  moetemp
  committed
  3c79510
- Milestone 1 gate: 53 of 55, and two honest gaps
  
  authored and
  moetemp
  committed
  8ab01be
- Case 29: reach the window it names, and state what actually blocks it
  
  authored and
  moetemp
  committed
  3f68a8a
- Fix four more defects the handoff case exposed, and take the gate to 54 of 55
  
  authored and
  moetemp
  committed
  987c9f7
- Close the deadlock: report the quiescent snapshot even when commands ride along
  
  authored and
  moetemp
  committed
  e878e21
- Close case 36: an empty stream parks, is evicted, and replays from its marker
  
  authored and
  moetemp
  committed
  01fb3fd
- Read the required-test lists from their own directory
  
  authored and
  moetemp
  committed
  890af9d
- Bind each wait to its own backend, and stop reporting unsent wakes as sent
  
  authored and
  moetemp
  committed
  0a157b5
- Make readiness reporting total, and stop dropping a stale answer
  
  authored and
  moetemp
  committed
  7458e1e
- Make the Redis key layout injective, and stop a stream name widening a scan
  
  authored and
  moetemp
  committed
  08b78f1
- Make merge fair, and stop consuming a record before it decodes
  
  authored and
  moetemp
  committed
  8be6ec4
- Reconcile an inherited park intent, and make parking match Core's wait set
  
  authored and
  moetemp
  committed
  1358c17
- Bind a late subscription, and replay a segment in its recorded order
  
  authored and
  moetemp
  committed
  f7c65f7
- Require a provider's key derivation to be injective
  
  authored and
  moetemp
  committed
  1c7ee60
- Decode off the Workflow thread, and connect the failure taxonomy
  
  authored and
  moetemp
  committed
  ae8a561
- Ask the converter's public members, not a predicate marked for removal
  
  authored and
  moetemp
  committed
  0dd5ba9
- Finish close(): stop the watcher and take back the park intent
  
  authored and
  moetemp
  committed
  34abed5
- Guard the close() teardown, none of which was tested
  
  authored and
  moetemp
  committed
  e37a63c
- Close the seven follow-up findings, which were all failure paths
  
  authored and
  moetemp
  committed
  99729cc
- Close the third review's six findings, and the seven the fixes introduced
  
  authored and
  moetemp
  committed
  02eb1ed
- Settle the Run before asking the status probe to be repeatable
  
  authored and
  moetemp
  committed
  90002e2
- Re-announce buffered records on every completion, not only a budget stop
  
  authored and
  moetemp
  committed
  668c0c2
- Close the fourth review's five findings, and the one its own fix left open
  
  authored and
  moetemp
  committed
  2620ee1
- Bind the unknown-append recovery to its operation, stream and producer
  
  authored and
  moetemp
  committed
  952ec2a
- Keep one canonical operation across repeated unknown-append recoveries
  
  authored and
  moetemp
  committed
  a0ebb24
- Close out the agent handoff notes, and the one defect they left open
  
  mfateev
  authored and
  moetemp
  committed
  a6e7ae2
- Close the fifth review's four findings
  
  authored and
  moetemp
  committed
  2de43e9
- Close the fifth review's remaining findings, including one in its own fix
  
  authored and
  moetemp
  committed
  7d2f91a
- Let the continuation writer be staged behind its reader
  
  authored and
  moetemp
  committed
  81b518d
- Name the writer stage, and run a chain through it
  
  authored and
  moetemp
  committed
  b4aaf04
- Let a merged wait end for every member, not only its winner
  
  authored and
  moetemp
  committed
  f7fa7c7
- State the merged wait's contract where it belongs, and cover its claim
  
  authored and
  moetemp
  committed
  381e177
- Validate recorded stream state against History, not against configuration
  
  authored and
  moetemp
  committed
  bae10ec
- Draw the unparked wake counter from the sender, not from the Run
  
  authored and
  moetemp
  committed
  60f451c
- Retry an owed park removal without waiting for another event
  
  authored and
  moetemp
  committed
  6c71094
- Close six findings in the owed-removal retry, one in its own fix
  
  authored and
  moetemp
  committed
  f4a0425
- Carry the wake a retired park intent owes past its subscription
  
  authored and
  moetemp
  committed
  d66f29a
- Stop three streaming tests failing on things they do not test
  
  authored and
  moetemp
  committed
  94a7a23
- Coalesce external stream wake cycles
  
  mfateev
  authored and
  moetemp
  committed
  5897602
- Correlate wake retries with task attempts
  
  mfateev
  authored and
  moetemp
  committed
  e1dba93
- Stabilize sandboxed handoff fixtures
  
  mfateev
  authored and
  moetemp
  committed
  7f063c5
- Await streaming worker test shutdown
  
  mfateev
  authored and
  moetemp
  committed
  9dac2cc
- Keep pytest rewriting out of workflow sandboxes
  
  mfateev
  authored and
  moetemp
  committed
  b1cc1a5
- Format streaming issue fixes
  
  mfateev
  authored and
  moetemp
  committed
  afd9730
- Document and type-check streaming support
  
  mfateev
  authored and
  moetemp
  committed
  776bed2
- Point streaming docs at current design
  
  mfateev
  authored and
  moetemp
  committed
  e68425b
- Use a single external stream backend
  
  mfateev
  authored and
  moetemp
  committed
  d00168e
- Expose external workflow stream APIs
  
  mfateev
  authored and
  moetemp
  committed
  12f35b7
- Implement workflow-originated external streams
  
  mfateev
  authored and
  moetemp
  committed
  5ed2941
- Update Core streaming documentation
  
  mfateev
  authored and
  moetemp
  committed
  6857a4a
- Moved the External Workflow Streams changelog entries to Unreleased.
  moetemp
  committed
  3e36f0b
- Held the server-backed stream cases off the skipping clock.
  moetemp
  committed
  b7f096e
- Made the external stream docstrings build under pydoctor.
  moetemp
  committed
  eb27fe7
- Aligned the external stream input and output replay schedules.
  moetemp
  committed
  bead929
- Kept a replay marker from earning a drain of its own.
  moetemp
  committed
  e3c49e9
- Allowed external-stream publishes from the workflow constructor.
  moetemp
  committed
  3769016
- Covered a publish from the workflow constructor in the conformance suite.
  moetemp
  committed
  56ff0b8
- Answered a legacy query without the stream snapshot beside it.
  moetemp
  committed
  aee1fe0
- Pointed the legacy query id at Core's own constant.
  moetemp
  committed
  c94d993
- Woke parked external readers through the stream's channel.
  moetemp
  committed
  2c83ee6
- Covered the external runtime's channel wake.
  moetemp
  committed
  69c9c20
- Covered the channel wake in the conformance suite.
  moetemp
  committed
  5ddbdba
- Let an external stream subscription name its start and yield offsets.
  moetemp
  committed
  933d1e1
- Added the Redis provider over External Workflow Streams.
  moetemp
  committed
  f857d24
- Covered the Redis provider.
  moetemp
  committed
  06a1ffc
- Said which provider carries a reader across continue-as-new.
  moetemp
  committed
  9cbac11
- Described the Redis provider's one log per topic in the changelog.
  moetemp
  committed
  398e932
- Trimmed the Redis streams by retention on every append.
  moetemp
  committed
  4f0065c
- Covered the Redis retention trims.
  moetemp
  committed
  8022baf
- Held an activity's own streams on the Redis provider.
  moetemp
  committed
  86af499
- Covered activity-owned streams on the Redis provider.
  moetemp
  committed
  544c021
- Let an external stream subscription start at the tail or the newest N.
  moetemp
  committed
  121eaed
- Let a Redis workflow reader start at the tail or at the newest N records.
  moetemp
  committed
  88718cb
- Covered the Redis workflow reader's tail starts.
  moetemp
  committed
  1533839
- Bumped the Core pin to the suite-reconciled head.
  moetemp
  committed
  850526c
- Merged moe/AI-198-o7-py-1-core-pin into moe/AI-198-o7-py-2-import.
  moetemp
  committed
  f19765f
- Merged moe/AI-198-o7-py-2-import into moe/AI-198-o7-py-3-tooling.
  moetemp
  committed
  d9a66ec
- Merged moe/AI-198-o7-py-3-tooling into moe/AI-198-o7-py-4-replay-schedule.
  moetemp
  committed
  ee823cc
- Merged moe/AI-198-o7-py-4-replay-schedule into moe/AI-198-o7-py-5-constructor-publish.
  moetemp
  committed
  1c7bace
- Merged moe/AI-198-o7-py-5-constructor-publish into moe/AI-198-o7-py-6-parked-run-query.
  moetemp
  committed
  7787e55
- Merged moe/AI-198-o7-py-6-parked-run-query into moe/AI-198-o7-py-7-channel-wake.
  moetemp
  committed
  ddda20c
- Merged moe/AI-198-o7-py-7-channel-wake into moe/AI-198-o7-py-8-redis-provider.
  moetemp
  committed
  2ad4207
- Merged moe/AI-198-o7-py-8-redis-provider into moe/AI-198-o7-py-9-redis-trimming.
  moetemp
  committed
  3978468
- Merged moe/AI-198-o7-py-9-redis-trimming into moe/AI-198-o7-py-10-redis-activity-owners.
  moetemp
  committed
  52203df
- Merged moe/AI-198-o7-py-10-redis-activity-owners into moe/AI-198-o7-py-11-redis-start-positions.
  moetemp
  committed
  ec87862
- Hosted standalone streams on the Redis provider.
  moetemp
  committed
  be39a8c
- Covered standalone streams on the Redis provider.
  moetemp
  committed
  4f3ff45
- Aborted a dead output stage when the Worker evicts its run.
  moetemp
  committed
  2b9be04
- Covered the dead stage abort on the Redis provider.
  moetemp
  committed
  c44bfde
- Merged the native main chain into the union.
  moetemp
  committed
  29aaa94
- Merged the external chain into the union.
  moetemp
  committed
  c40987e
- Merged the time-skipping unlock fix into the union.
  moetemp
  committed
  5d72e71
- Skipped the native conformance setup without a server address.
  moetemp
  committed
  02d4ecd
- Ran the native provider cases in the union.
  moetemp
  committed
  477b78f
- Consumed a Redis stream through the channel its producer notifies.
  moetemp
  committed
  268215b
- Ran the demo on each of the union's four providers.
  moetemp
  committed
  29cfd44
- Fixed the visitor generator's repeated-field check.
  moetemp
  committed
  9128bb0
- Merged the v4 union into the examples.
  moetemp
  committed
  9320b44

Commits

Commits on Oct 2, 2026

Commits on Oct 3, 2026

Commits on Oct 5, 2026