Bound Redis to the stream interface as RedisStreams. - #17

Closed

moedash wants to merge 114 commits into

moe/AI-198-py-09-external-interfacefrom

moe/AI-198-py-10-redis-provider

Commits on Sep 6, 2026

Align external stream input and output replay schedules
mdashti
committed
75de955
Preserve stream task retention with zero workflow cache
mdashti
committed
c00339e

Commits on Sep 14, 2026

Put the shared stream interface on the repaired external SDK.
moedash
committed
632e16f
Let a terminal record land on a consumer that is closing.
moedash
committed
66f353c

Commits on Sep 15, 2026

Commits on Sep 16, 2026

Added the prepare and drain hooks the Workflow Streams transport needs.
moedash
committed
af2483d
Made cursors exclusive, added latest(), and allowed topic appends.
moedash
committed
0741345
Made cursors exclusive, added latest(), and allowed topic appends.
moedash
committed
fb74e79
Applied an external stream replay marker before the task's first drain.
moedash
committed
295fe3f
Sorted and formatted the streams package for ruff.
moedash
committed
668e432
Made the streams package pass the type and doc linters.
moedash
committed
0877fe4
Made the Redis provider pass the linters.
moedash
committed
29cc1cb
Gave the external stream test fakes the shapes the real path has.
moedash
committed
89c1a37
Snapshotted the markers where the abandoned task begins.
moedash
committed
97849a8
Added the changelog entry for the shared stream interface.
moedash
committed
d963173
Made the demo call the provider lifecycle hooks.
moedash
committed
5bf0094

Commits on Sep 17, 2026

Support google-genai 2.21 file downloads (#1865)

brianstrauch
authored and
moedash
committed
105ad9b
Fix tests with latest dependencies (#1798)

brianstrauch
authored and
moedash
committed
e69ad05
Adopted main's Nexus system API generator script.
moedash
committed
914ee40
Loosened the status error's response annotation.
moedash
committed
14b5042
Held the external stream suite off the time-skipping server.
moedash
committed
c4bed86
Gave each mock tool call its own id.
moedash
committed
86dc631
Repinned Core to the finalized external repairs branch.
moedash
committed
c27c620
Regenerated the Nexus system API from the repinned Core.
moedash
committed
6b34091
Adopted main's payload visitor generator.
moedash
committed
9437d75
Made the external stream docstrings build under pydoctor.
moedash
committed
e6007d3

Commits on Sep 19, 2026

Commits on Sep 21, 2026

Added the StreamError family for stream conditions.
moedash
committed
362b643
Vendored the stream additions to the public API protos.
moedash
committed
600f6d5
Split the stream provider in two and made the proto the record.
moedash
committed
4362c31
Carried the stream provider from the worker into the workflow runtime.
moedash
committed
e05e651
Moved the stream conformance suite onto the new surface.
moedash
committed
d37f8ad
Moved the stream demo and changelog entry onto the new surface.
moedash
committed
1ea907c
Rewrote the Redis provider with an input and an output stream per topic.
moedash
committed
2659a17
Kept the stream finish hook off evicted runs and collected coroutines.
moedash
committed
88a6298
Typed the hook test's workflow input as awaitable.
moedash
committed
d11aa01
Added activity.stream_handle and Client.get_stream_handle.
moedash
committed
4995cf1
Registered the demo's provider on the client and reported from the activity.
moedash
committed
dc32947
Registered the Redis conformance provider on the client.
moedash
committed
a667640
Added typed topic definitions.
moedash
committed
be743fd
Took topic definitions on the Redis handle.
moedash
committed
c37b351
Matched the Redis live module to typed topic definitions.
moedash
committed
a9bda0f
Seeded a Redis workflow reader from a cursor.
moedash
committed
62b57e3
Passed a backend's integrity loss through the replay read.
moedash
committed
c7e30af
Trimmed the Redis streams by retention on every append.
moedash
committed
d87787d

Commits on Sep 22, 2026

Listed stream_provider in ClientConnectConfig.
moedash
committed
4b6d572
Answered a legacy query without the stream snapshot beside it.
moedash
committed
6ec392f
Repinned Core to the repairs head that carries the stream protos.
moedash
committed
d3aeb56

Commits on Sep 25, 2026

Added the Redis provider with an input and an output stream per topic.
moedash
committed
b7be7b4
Seeded a Redis workflow reader from a cursor.
moedash
committed
e578e67
Trimmed the Redis streams by retention on every append.
moedash
committed
84c77d4
Tied the series to the original branch head.
moedash
committed
2a5593c
Merged the external interface with the review-round fixes.
moedash
committed
66eaaff
Repaired the Redis provider's writes, refusals and error family.
moedash
committed
bb2d7ca
Ran the Redis stream tests in CI against a service container.
moedash
committed
17a308e

Commits on Sep 26, 2026

Merge branch 'moe/AI-198-py-09-external-interface' into moe/AI-198-py-10-redis-provider
moedash
committed
aaccdda

Commits on Sep 29, 2026

Merge branch 'moe/AI-198-py-09-external-interface' into moe/AI-198-py-10-redis-provider
moedash
committed
0380e06

Commits on Sep 30, 2026

Commits on Oct 1, 2026

Commits on Oct 2, 2026

Commits on Oct 3, 2026