Repository navigation

Merged both Python chains into one union. - #55

Closed

moetemp wants to merge 212 commits into

mainfrom

moe/AI-198-st-py-union

Closed

Merged both Python chains into one union.#55
moetemp wants to merge 212 commits into
mainfrom
moe/AI-198-st-py-union

Commits on Aug 14, 2026
- Move sdk-core submodule to 6e90e6d5 and fix bridge build
  
  mfateev
  and
  claude
  committed
  ec20038
Commits on Aug 15, 2026
- Point the Core submodule at the task fork branch
  mfateev
  committed
  8cdaa2e
- External streams: generated protos, record model, and the Redis fixture
  
  mfateev
  and
  claude
  committed
  245ccba
- External streams: backend contract, annotation codec, codec, failure taxonomy
  
  mfateev
  and
  claude
  committed
  e179ab6
- External streams: parking contract, Redis provider, registry, producer, bridge
  
  mfateev
  and
  claude
  committed
  42ff459
- External streams: subscription manager and the Workflow-facing API
  
  mfateev
  and
  claude
  committed
  f9b199e
Commits on Aug 16, 2026
- External streams: regenerate protos for the marker terminal reasons
  
  mfateev
  and
  claude
  committed
  e533438
- External streams: wire the feature into the Python Worker
  
  mfateev
  and
  claude
  committed
  4c6ddc5
- P13: the replay read path
  
  mfateev
  and
  claude
  committed
  4f95dbe
- P14: the producer wake-signal path
  
  mfateev
  and
  claude
  committed
  f9ee870
- P6b: publish()'s acknowledged-wake semantics
  
  mfateev
  and
  claude
  committed
  65e48fa
- P15: the Continue-As-New cursor
  
  mfateev
  and
  claude
  committed
  6fbd4dc
- P21: multiple streams, merge, and same-stream subscriptions
  
  mfateev
  and
  claude
  committed
  c25123a
- P20: the Worker shutdown wake sweep
  
  mfateev
  and
  claude
  committed
  f202383
- P16b: the Milestone 2 required-test list
  
  mfateev
  and
  claude
  committed
  ead7644
- Fix the failure-taxonomy row for an annotation mismatch, and P20's missing retry
  
  mfateev
  and
  claude
  committed
  4d8bdcf
- P16a/P16b: make the milestone gates enforceable
  
  mfateev
  and
  claude
  committed
  3cc7c24
- Core bump for C8/C10, and three more Milestone 1 cases
  
  mfateev
  and
  claude
  committed
  d6ed30a
- Replay a stream history through the real Replayer
  
  mfateev
  and
  claude
  committed
  6bfe3cf
- Deliver a record buffered while Workflow code was elsewhere
  
  mfateev
  and
  claude
  committed
  8e58be1
- Core bump for C15b, and correct a replay finding made against a stale bridge
  
  mfateev
  and
  claude
  committed
  d191bbd
Commits on Aug 17, 2026
- The livelock does not exist: fix the test helper that caused it
  
  mfateev
  and
  claude
  committed
  b30b3df
- Bound delivery within one activation (ADR-026)
  
  mfateev
  and
  claude
  committed
  7313e00
- Fix four defects the required-test list exposed
  
  mfateev
  and
  claude
  committed
  faa1c84
- Make an unparked wake's sender identity unique per sender
  
  mfateev
  and
  claude
  committed
  838810f
- Rollover cases: one test defect fixed, two reasons corrected
  
  mfateev
  and
  claude
  committed
  c70ec80
- Core bump: the replay flag fix
  
  mfateev
  and
  claude
  committed
  08f1206
- Rollover cases 19 and 23: both were test defects
  
  mfateev
  and
  claude
  committed
  ca4008d
- Milestone 1 gate: 53 of 55, and two honest gaps
  
  mfateev
  and
  claude
  committed
  ac12d27
- Case 29: reach the window it names, and state what actually blocks it
  
  mfateev
  and
  claude
  committed
  0ce689d
Commits on Aug 18, 2026
- Fix four more defects the handoff case exposed, and take the gate to 54 of 55
  
  mfateev
  and
  claude
  committed
  c301f17
- Close the deadlock: report the quiescent snapshot even when commands ride along
  
  mfateev
  and
  claude
  committed
  93f0306
- Close case 36: an empty stream parks, is evicted, and replays from its marker
  
  mfateev
  and
  claude
  committed
  8d5ee1f
- Read the required-test lists from their own directory
  
  mfateev
  and
  claude
  committed
  62b3ff1
- Core bump: the review guide
  
  mfateev
  and
  claude
  committed
  b87e094
- Core bump: the review guide as a usable root
  
  mfateev
  and
  claude
  committed
  e6d4cd9
- Bind each wait to its own backend, and stop reporting unsent wakes as sent
  
  mfateev
  and
  claude
  committed
  a9c03ec
- Make readiness reporting total, and stop dropping a stale answer
  
  mfateev
  and
  claude
  committed
  0c92c99
- Make the Redis key layout injective, and stop a stream name widening a scan
  
  mfateev
  and
  claude
  committed
  ee4fbf8
- Make merge fair, and stop consuming a record before it decodes
  
  mfateev
  and
  claude
  committed
  03969db
- Reconcile an inherited park intent, and make parking match Core's wait set
  
  mfateev
  and
  claude
  committed
  0442dc4
- Bind a late subscription, and replay a segment in its recorded order
  
  mfateev
  and
  claude
  committed
  1e369ec
- Require a provider's key derivation to be injective
  
  mfateev
  and
  claude
  committed
  7e040b7
- Decode off the Workflow thread, and connect the failure taxonomy
  
  mfateev
  and
  claude
  committed
  8ac891f
- Ask the converter's public members, not a predicate marked for removal
  
  mfateev
  and
  claude
  committed
  18a93e5
- Vendor the documents the review guide points at
  
  mfateev
  and
  claude
  committed
  1e94c30
Commits on Aug 19, 2026
- Finish close(): stop the watcher and take back the park intent
  
  mfateev
  and
  claude
  committed
  88c3578
- Guard the close() teardown, none of which was tested
  
  mfateev
  and
  claude
  committed
  8c2ff85
- Point sdk-core at the close() documentation
  
  mfateev
  and
  claude
  committed
  cbb832a
- Close the seven follow-up findings, which were all failure paths
  
  mfateev
  and
  claude
  committed
  2763a25
- Point sdk-core at the follow-up review documentation
  
  mfateev
  and
  claude
  committed
  5a88733
- Close the third review's six findings, and the seven the fixes introduced
  
  mfateev
  and
  claude
  committed
  8abb8eb
- Point sdk-core at the third review documentation
  
  mfateev
  and
  claude
  committed
  bf33670
- Settle the Run before asking the status probe to be repeatable
  
  mfateev
  and
  claude
  committed
  bff3f44
- Re-announce buffered records on every completion, not only a budget stop
  
  mfateev
  and
  claude
  committed
  e3c0571
- Close the fourth review's five findings, and the one its own fix left open
  
  mfateev
  and
  claude
  committed
  0836355
- Bind the unknown-append recovery to its operation, stream and producer
  
  mfateev
  and
  claude
  committed
  88e3af7
Commits on Aug 20, 2026
- Keep one canonical operation across repeated unknown-append recoveries
  
  mfateev
  and
  claude
  committed
  4827835
- Point sdk-core at the repeated-recovery documentation
  
  mfateev
  and
  claude
  committed
  6d7d193
- Close out the agent handoff notes, and the one defect they left open
  mfateev
  committed
  065e7f5
- Close the fifth review's four findings
  
  mfateev
  and
  claude
  committed
  5ab10ac
Commits on Aug 21, 2026
- Close the fifth review's remaining findings, including one in its own fix
  
  mfateev
  and
  claude
  committed
  51e829f
- Point sdk-core at the fifth review's documentation
  
  mfateev
  and
  claude
  committed
  0076f3d
- Let the continuation writer be staged behind its reader
  
  mfateev
  and
  claude
  committed
  3992263
- Point sdk-core at the staged-writer decision
  
  mfateev
  and
  claude
  committed
  081a949
- Name the writer stage, and run a chain through it
  
  mfateev
  and
  claude
  committed
  6c5e324
- Let a merged wait end for every member, not only its winner
  
  mfateev
  and
  claude
  committed
  5cb918b
- State the merged wait's contract where it belongs, and cover its claim
  
  mfateev
  and
  claude
  committed
  d73575f
- Point sdk-core at the merged-wait blocked-set statement
  
  mfateev
  and
  claude
  committed
  8a4680d
Commits on Aug 22, 2026
- Validate recorded stream state against History, not against configuration
  
  mfateev
  and
  claude
  committed
  601ca54
- Draw the unparked wake counter from the sender, not from the Run
  
  mfateev
  and
  claude
  committed
  f8aca38
- Retry an owed park removal without waiting for another event
  
  mfateev
  and
  claude
  committed
  72d5b8d
- Point sdk-core at the autonomous owed-removal decision
  
  mfateev
  and
  claude
  committed
  f36a9a0
- Close six findings in the owed-removal retry, one in its own fix
  
  mfateev
  and
  claude
  committed
  e03eb25
- Point sdk-core at the bound, owned and announced cleanup
  
  mfateev
  and
  claude
  committed
  e73ee2c
Commits on Aug 23, 2026
- Carry the wake a retired park intent owes past its subscription
  
  mfateev
  and
  claude
  committed
  7392fbd
- Point sdk-core at the buffered Workflow Task admission fix
  
  mfateev
  and
  claude
  committed
  85aa5c5
Commits on Aug 24, 2026
- Point sdk-core at the open-issues register
  
  mfateev
  and
  claude
  committed
  d9ccd4d
- Stop three streaming tests failing on things they do not test
  
  mfateev
  and
  claude
  committed
  50de639
- Coalesce external stream wake cycles
  mfateev
  committed
  82b3c7d
- Correlate wake retries with task attempts
  mfateev
  committed
  86144a0
- Point sdk-core at defensive WFT admission
  mfateev
  committed
  163019c
- Stabilize sandboxed handoff fixtures
  mfateev
  committed
  4eca5b4
- Await streaming worker test shutdown
  mfateev
  committed
  2994f4f
- Keep pytest rewriting out of workflow sandboxes
  mfateev
  committed
  bff2571
- Format streaming issue fixes
  mfateev
  committed
  552e4f0
- Document and type-check streaming support
  mfateev
  committed
  380fe87
- Record final Core streaming validation
  mfateev
  committed
  d40a076
Commits on Aug 25, 2026
- Point streaming docs at current design
  mfateev
  committed
  7e9c821
Commits on Aug 26, 2026
- Use a single external stream backend
  mfateev
  committed
  858669c
- Expose external workflow stream APIs
  mfateev
  committed
  4a49e4f
- Update external streams design proposal
  mfateev
  committed
  2e3e38c
Commits on Aug 27, 2026
- Implement workflow-originated external streams
  mfateev
  committed
  1d7b073
- Update SDK Core streaming proposal
  mfateev
  committed
  c5f2d8e
- Update Core streaming documentation
  mfateev
  committed
  d921fe7
Commits on Sep 29, 2026
- Shared one time-skipping unlock between concurrent result waiters.
  moetemp
  committed
  2efc738
- Waited for the target workflow to close before the update that must fail.
  moetemp
  committed
  370bfa9
Commits on Oct 3, 2026
- Backported the upstream fixes for the latest dependency set.
  moetemp
  committed
  6728823
- Adopted main's generator scripts and regenerated their output.
  moetemp
  committed
  34c5e90
- Repinned Core to upstream main and brought the bridge up to it.
  moetemp
  committed
  1cff589
- Pinned the channel Core and regenerated the channel protos.
  moetemp
  committed
  89871a2
- Added Execution and ExecutionType to temporalio.common.
  moetemp
  committed
  02d494d
- Added the notification channel calls to the client.
  moetemp
  committed
  f8bf154
- Covered the client channel calls.
  moetemp
  committed
  7838fa1
- Added channel subscriptions to the workflow runtime.
  moetemp
  committed
  34cf5f4
- Listed a run's channel subscriptions on its description.
  moetemp
  committed
  f04fe11
- Covered the workflow channel surface.
  moetemp
  committed
  ef6ca30
- Pinned the Core that vendors the stream record envelope.
  moetemp
  committed
  8607599
- Pinned Core at the channel machines on the external base.
  moetemp
  committed
  e9cbce5
- Added the temporalio.streams interface types.
  moetemp
  committed
  798c1cb
- Carried a stream provider on client, worker and replayer config.
  moetemp
  committed
  b558185
- Covered the stream interface types.
  moetemp
  committed
  3dd3479
- Added Execution and ExecutionType to temporalio.common.
  moetemp
  committed
  bc887e4
- Added MemoryStreams, the in-memory reference provider.
  moetemp
  committed
  bc77a84
- Added the provider conformance suite and ran it on memory.
  moetemp
  committed
  a6af595
- Added the notification channel calls to the client.
  moetemp
  committed
  8a7e2a6
- Covered the client channel calls.
  moetemp
  committed
  f3f6dfb
- Added workflow.stream_reader and workflow.stream_writer.
  moetemp
  committed
  fdd81d3
- Ran the stream provider's lifecycle hooks around the workflow.
  moetemp
  committed
  732e0d2
- Covered the workflow stream runtime.
  moetemp
  committed
  7bc1c11
- Added channel subscriptions to the workflow runtime.
  moetemp
  committed
  af1ee40
- Listed a run's channel subscriptions on its description.
  moetemp
  committed
  0db172e
- Covered the workflow channel surface.
  moetemp
  committed
  ed12a9f
- Added the stream accessors for activities and clients.
  moetemp
  committed
  d220153
- Covered the stream accessors.
  moetemp
  committed
  d917032
- Added stream_channel to name the channel a stream notifies.
  moetemp
  committed
  67efbda
- Added a changelog entry for the stream interface.
  moetemp
  committed
  5460ca2
- Added a streams demo that runs the agent loop on a provider.
  moetemp
  committed
  c4ca2fd
- Opened hooks in contrib.workflow_streams for a stream provider.
  moetemp
  committed
  536c905
- Added the Workflow Streams stream provider.
  moetemp
  committed
  eb5ebfb
- Ran the conformance suite on the Workflow Streams provider.
  moetemp
  committed
  99a55aa
- Added the Temporal Streams Nexus contract and its generated bindings.
  moetemp
  committed
  9193dd7
- Added the Nexus front for stream providers.
  moetemp
  committed
  b8a7a3c
- Covered the Nexus front.
  moetemp
  committed
  43629ca
- Added a Nexus operation that consumes a stream through its channel.
  moetemp
  committed
  19cbdd7
- Added a standalone aiohttp host for the stream consumer operation.
  moetemp
  committed
  1646132
- Covered the Nexus stream consumer operation.
  moetemp
  committed
  97afa38
- Warned when a producer's attempt goes backwards on a read.
  moetemp
  committed
  3f93403
- Refused a stream publish from a query handler at the call.
  moetemp
  committed
  bbc5b45
- Pinned the stream Core and regenerated the stream api protos.
  moetemp
  committed
  898c3af
- Held the server-backed stream cases off the skipping clock.
  moetemp
  committed
  2683dd2
- Vendored the server's stream service protos.
  moetemp
  committed
  ce19b35
- Added a client for the server-side stream service.
  moetemp
  committed
  6f2f9ad
- Covered the stream service client.
  moetemp
  committed
  5220369
- Made the external stream docstrings build under pydoctor.
  moetemp
  committed
  0b2172f
- Shared, retried and codec-aware connections in the stream client.
  moetemp
  committed
  ba5a02a
- Added the native stream commands to the workflow runtime.
  moetemp
  committed
  2fa3b3c
- Added contrib.server_streams over a native stream.
  moetemp
  committed
  6643bae
- Added the native stream provider.
  moetemp
  committed
  414e3bf
- Replayed workflows that read native streams.
  moetemp
  committed
  c6a50b8
- Covered replay of native stream reads.
  moetemp
  committed
  bedc0e9
- Added a changelog entry for server-side streams.
  moetemp
  committed
  93f03ea
- Removed a demo run's output from the streams demo.
  moetemp
  committed
  27385ea
- Merged moe/AI-198-if-py-6-demo into moe/AI-198-if-py-7-workflow-streams-provider.
  moetemp
  committed
  f631aed
- Merged moe/AI-198-if-py-7-workflow-streams-provider into moe/AI-198-if-py-8-nexus-front.
  moetemp
  committed
  f6ab743
- Merged moe/AI-198-if-py-8-nexus-front into moe/AI-198-if-py-9-nexus-consumer.
  moetemp
  committed
  8f9dafe
- Merged moe/AI-198-if-py-9-nexus-consumer into moe/AI-198-if-py-10-backwards-attempt-warning.
  moetemp
  committed
  432b7bd
- Merged moe/AI-198-if-py-10-backwards-attempt-warning into moe/AI-198-if-py-11-query-publish-refusal.
  moetemp
  committed
  a6c758a
- Merged moe/AI-198-if-py-11-query-publish-refusal into moe/AI-198-st-py-1-core-pin.
  moetemp
  committed
  79dc5f6
- Merged moe/AI-198-st-py-1-core-pin into moe/AI-198-st-py-2-native-wire.
  moetemp
  committed
  548d574
- Merged moe/AI-198-st-py-2-native-wire into moe/AI-198-st-py-3-native-provider.
  moetemp
  committed
  000bd20
- Merged moe/AI-198-st-py-3-native-provider into moe/AI-198-st-py-4-native-replay.
  moetemp
  committed
  bbb5159
- Pinned Core at the external-stream repairs.
  moetemp
  committed
  e602e41
- Aligned the external stream input and output replay schedules.
  moetemp
  committed
  28ad8af
- Kept a replay marker from earning a drain of its own.
  moetemp
  committed
  166a6ff
- Allowed external-stream publishes from the workflow constructor.
  moetemp
  committed
  b8b3bbb
- Pinned Core at the external runtime's channel wake.
  moetemp
  committed
  c49846c
- Woke parked external readers through the stream's channel.
  moetemp
  committed
  73ab2c6
- Covered the external runtime's channel wake.
  moetemp
  committed
  9dfded4
- Answered a legacy query without the stream snapshot beside it.
  moetemp
  committed
  0aa1927
- Pointed the legacy query id at Core's own constant.
  moetemp
  committed
  0c63317
- Added the temporalio.streams interface on the external base.
  moetemp
  committed
  bce9b70
- Covered the stream interface with the conformance suite.
  moetemp
  committed
  579cd92
- Added the stream interface demo.
  moetemp
  committed
  ac46576
- Let an external stream subscription name its start and yield offsets.
  moetemp
  committed
  6250dfe
- Added the Redis provider over External Workflow Streams.
  moetemp
  committed
  640e594
- Covered the Redis provider.
  moetemp
  committed
  69213bc
- Trimmed the Redis streams by retention on every append.
  moetemp
  committed
  44b0b87
- Covered the Redis retention trims.
  moetemp
  committed
  eff9b2c
- Held an activity's own streams on the Redis provider.
  moetemp
  committed
  fb396fe
- Covered activity-owned streams on the Redis provider.
  moetemp
  committed
  a445ad9
- Let an external stream subscription start at the tail or the newest N.
  moetemp
  committed
  2896240
- Let a Redis workflow reader start at the tail or at the newest N records.
  moetemp
  committed
  da2588b
- Covered the Redis workflow reader's tail starts.
  moetemp
  committed
  e4389c4
- Hosted standalone streams on the Redis provider.
  moetemp
  committed
  102cd7e
- Covered standalone streams on the Redis provider.
  moetemp
  committed
  3a82166
- Aborted a dead output stage when the Worker evicts its run.
  moetemp
  committed
  bc2786c
- Covered the dead stage abort on the Redis provider.
  moetemp
  committed
  28ad9d9
- Said which provider carries a reader across continue-as-new.
  moetemp
  committed
  13703e7
- Merged the stream_reader docstring fix forward.
  moetemp
  committed
  d2b79e9
- Merged the stream_reader docstring fix forward.
  moetemp
  committed
  79a50f7
- Merged the stream_reader docstring fix forward.
  moetemp
  committed
  86bd821
- Merged the stream_reader docstring fix forward.
  moetemp
  committed
  aade62e
- Merged the stream_reader docstring fix forward.
  moetemp
  committed
  95d49f6
- Described the Redis provider's one log per topic in the changelog.
  moetemp
  committed
  f1b65f9
- Merged the native main chain into the union.
  moetemp
  committed
  936f443
- Merged the changelog wording fix forward.
  moetemp
  committed
  2fbcd31
- Merged the changelog wording fix forward.
  moetemp
  committed
  e8a395a
- Merged the changelog wording fix forward.
  moetemp
  committed
  0d854a9
- Merged the changelog wording fix forward.
  moetemp
  committed
  71bce94
- Merged the changelog wording fix forward.
  moetemp
  committed
  aa6c5e0
- Merged the external chain into the union.
  moetemp
  committed
  7dbff0c
- Merged the time-skipping unlock fix into the union.
  moetemp
  committed
  a2af60d
- Built the external channel tests' instances the way the worker does.
  moetemp
  committed
  0953f1c
- Numbered the Redis producer's records from one.
  moetemp
  committed
  cb21ff0
- Let a Redis stream handle default to the default topic.
  moetemp
  committed
  adec146
- Skipped the native conformance setup without a server address.
  moetemp
  committed
  37e0692
- Read the constructor-publish case while the worker still polls.
  moetemp
  committed
  d278a73
- Ran the native provider cases in the union.
  moetemp
  committed
  b4c2d2a
- Consumed a Redis stream through the channel its producer notifies.
  moetemp
  committed
  0a9b446
- Ran the demo on each of the union's four providers.
  moetemp
  committed
  75718d3
- Fixed the visitor generator's repeated-field check.
  moetemp
  committed
  992452f

Commits

Commits on Aug 14, 2026

Commits on Aug 15, 2026

Commits on Aug 16, 2026

Commits on Aug 17, 2026

Commits on Aug 18, 2026

Commits on Aug 19, 2026

Commits on Aug 20, 2026

Commits on Aug 21, 2026

Commits on Aug 22, 2026

Commits on Aug 23, 2026

Commits on Aug 24, 2026

Commits on Aug 25, 2026

Commits on Aug 26, 2026

Commits on Aug 27, 2026

Commits on Sep 29, 2026

Commits on Oct 3, 2026