Repository navigation

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

Closed

moetemp 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.
  moetemp
  committed
  7af879d
- Added the in-memory reference provider and the conformance tests.
  moetemp
  committed
  c2f0251
- Added the shared demo loop.
  moetemp
  committed
  2815caf
- Added the prepare and drain hooks the Workflow Streams transport needs.
  moetemp
  committed
  ccae2b4
- Made cursors exclusive, added latest(), and allowed topic appends.
  moetemp
  committed
  8926913
- Sorted and formatted the streams package for ruff.
  moetemp
  committed
  8e36829
- Added the changelog entry for the stream interface.
  moetemp
  committed
  a627022
- Made the streams package pass the type and doc linters.
  moetemp
  committed
  0fbac29
- Made the demo call the provider lifecycle hooks.
  moetemp
  committed
  6b8b35e
Commits on Sep 18, 2026
- Woke outside readers across threads and ignored idle_timeout in memory.
  moetemp
  committed
  696d355
- Named the last record in append's cursor and allowed None for it.
  moetemp
  committed
  ba75070
- Resolved producer identity once in the package.
  moetemp
  committed
  9de9342
- Required an explicit provider and exported instance.
  moetemp
  committed
  fe4ec72
- Typed the handles and records honestly.
  moetemp
  committed
  0af0389
- Kept topics off inbound frames and skipped unreadable frames with a warning.
  moetemp
  committed
  8a2bf8d
- Let a broken provider import surface instead of vanishing from the registry.
  moetemp
  committed
  35b1212
- Added the workflow-side conformance tests.
  moetemp
  committed
  6e48b54
- Replaced stale wording and renamed the demo types.
  moetemp
  committed
  360d054
Commits on Sep 19, 2026
Commits on Sep 21, 2026
- Added the StreamError family for stream conditions.
  moetemp
  committed
  144580c
- Vendored the stream additions to the public API protos.
  moetemp
  committed
  22d79ec
- Split the stream provider in two and made the proto the record.
  moetemp
  committed
  1effd48
- Carried the stream provider from the worker into the workflow runtime.
  moetemp
  committed
  ebbdfa2
- Moved the stream conformance suite onto the new surface.
  moetemp
  committed
  ffae7a4
- Moved the stream demo and changelog entry onto the new surface.
  moetemp
  committed
  3f16fd3
- Let a conformance case start the workflow that owns a stream.
  moetemp
  committed
  e5f21df
- Kept the stream finish hook off evicted runs and collected coroutines.
  moetemp
  committed
  2799b58
- Typed the hook test's workflow input as awaitable.
  moetemp
  committed
  297d3c5
- Added activity.stream_handle and Client.get_stream_handle.
  moetemp
  committed
  099c52c
- Registered the demo's provider on the client and reported from the activity.
  moetemp
  committed
  22e3864
- Added typed topic definitions.
  moetemp
  committed
  40bc91e
Commits on Sep 22, 2026
- Listed stream_provider in ClientConnectConfig.
  moetemp
  committed
  b068712
- Repinned Core to a protos-only branch on the commit main pins.
  moetemp
  committed
  1a8d19f

Commits

Commits on Sep 17, 2026

Commits on Sep 18, 2026

Commits on Sep 19, 2026

Commits on Sep 21, 2026

Commits on Sep 22, 2026