Added the stream accessors and tied in the interface head. - #13

Closed

moedash wants to merge 75 commits into

moe/AI-198-py-03-workflow-runtimefrom

moe/AI-198-py-04-accessors

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

Commits on Sep 25, 2026

Added activity.stream_handle.
moedash
committed
55200ec
Added Client.get_stream_handle and the connect keyword.
moedash
committed
e94d11d
Moved the conformance cases onto the client accessor.
moedash
committed
fe446e6
Added the streams demo and the changelog entry.
moedash
committed
717f58b
Tied the series to the original branch head.
moedash
committed
2337651
Merge branch 'moe/AI-198-py-03-workflow-runtime' into moe/AI-198-py-04-accessors
moedash
committed
c84eb66
Told a sync activity what it is actually missing.
moedash
committed
fc92161
Put the streams demo under the type checkers.
moedash
committed
e57bd02
Merge branch 'moe/AI-198-py-03-workflow-runtime' into moe/AI-198-py-04-accessors
moedash
committed
a03d091
Merge branch 'moe/AI-198-py-03-workflow-runtime' into moe/AI-198-py-04-accessors
moedash
committed
64530d0

Commits on Sep 26, 2026

Merge branch 'moe/AI-198-py-03-workflow-runtime' into moe/AI-198-py-04-accessors
moedash
committed
9a41d49

Commits on Sep 28, 2026

Commits on Sep 30, 2026

Commits on Oct 2, 2026

Commits on Oct 3, 2026