Added the stream interface, the memory provider and the conformance suite. - #3

Closed

moedash wants to merge 36 commits into

mainfrom

moe/AI-198-streams-interface

Commits on Sep 17, 2026

Added the temporalio.streams interface with a provider registry.
moedash
committed
7af879d
Added the in-memory reference provider and the conformance tests.
moedash
committed
c2f0251
Added the shared demo loop.
moedash
committed
2815caf
Added the prepare and drain hooks the Workflow Streams transport needs.
moedash
committed
ccae2b4
Made cursors exclusive, added latest(), and allowed topic appends.
moedash
committed
8926913
Sorted and formatted the streams package for ruff.
moedash
committed
8e36829
Added the changelog entry for the stream interface.
moedash
committed
a627022
Made the streams package pass the type and doc linters.
moedash
committed
0fbac29
Made the demo call the provider lifecycle hooks.
moedash
committed
6b8b35e

Commits on Sep 18, 2026

Woke outside readers across threads and ignored idle_timeout in memory.
moedash
committed
696d355
Named the last record in append's cursor and allowed None for it.
moedash
committed
ba75070
Resolved producer identity once in the package.
moedash
committed
9de9342
Required an explicit provider and exported instance.
moedash
committed
fe4ec72
Typed the handles and records honestly.
moedash
committed
0af0389
Kept topics off inbound frames and skipped unreadable frames with a warning.
moedash
committed
8a2bf8d
Let a broken provider import surface instead of vanishing from the registry.
moedash
committed
35b1212
Added the workflow-side conformance tests.
moedash
committed
6e48b54
Replaced stale wording and renamed the demo types.
moedash
committed
360d054

Commits on Sep 21, 2026

Added the StreamError family for stream conditions.
moedash
committed
144580c
Vendored the stream additions to the public API protos.
moedash
committed
22d79ec
Split the stream provider in two and made the proto the record.
moedash
committed
1effd48
Carried the stream provider from the worker into the workflow runtime.
moedash
committed
ebbdfa2
Moved the stream conformance suite onto the new surface.
moedash
committed
ffae7a4
Moved the stream demo and changelog entry onto the new surface.
moedash
committed
3f16fd3
Let a conformance case start the workflow that owns a stream.
moedash
committed
e5f21df
Kept the stream finish hook off evicted runs and collected coroutines.
moedash
committed
2799b58
Typed the hook test's workflow input as awaitable.
moedash
committed
297d3c5
Added activity.stream_handle and Client.get_stream_handle.
moedash
committed
099c52c
Registered the demo's provider on the client and reported from the activity.
moedash
committed
22e3864
Added typed topic definitions.
moedash
committed
40bc91e

Commits on Sep 22, 2026

Listed stream_provider in ClientConnectConfig.
moedash
committed
b068712
Repinned Core to a protos-only branch on the commit main pins.
moedash
committed
1a8d19f