Added one stream interface with its four providers and the Nexus front. - #6

Closed

moedash wants to merge 1186 commits into

mainfrom

moe/AI-198-streams-all

This pull request is big! We're only showing the most recent 250 commits

Commits on Sep 30, 2026

Merge remote-tracking branch 'origin/moe/AI-198-py-10-redis-provider' into moe/AI-198-streams-all
moedash
committed
a86473e

Commits on Oct 1, 2026

Commits on Oct 2, 2026

Commits on Oct 3, 2026

Pinned Core with a linked channel addressed by execution.
moedash
committed
2a9234c
Merge branch 'moe/AI-198-py-01-protos' into moe/AI-198-py-02-streams-package
moedash
committed
0013df7
Merge branch 'moe/AI-198-py-02-streams-package' into moe/AI-198-py-03-workflow-runtime
moedash
committed
f84b3c4
Pinned Core at the protos that address a channel by execution.
moedash
committed
49faf69
Addressed a linked channel by execution.
moedash
committed
a59c3a8
Merge branch 'moe/AI-198-py-08-external-repairs' into moe/AI-198-py-09-external-interface
moedash
committed
fbbaf0c
Read the linked owner as an execution in the conformance case.
moedash
committed
58baa2a
Merge branch 'moe/AI-198-py-09-external-interface' into moe/AI-198-py-10-redis-provider
moedash
committed
7e3c63f
Read the linked owner as an execution in the Redis replay case.
moedash
committed
7718b1e
Addressed a linked channel by execution on the client.
moedash
committed
d6b39ad
Merge branch 'moe/AI-198-py-03-workflow-runtime' into moe/AI-198-py-04-accessors
moedash
committed
10dd23f
Merge branch 'moe/AI-198-py-04-accessors' into moe/AI-198-streams-provider-workflow-streams
moedash
committed
6c73610
Merge branch 'moe/AI-198-streams-provider-workflow-streams' into moe/AI-198-py-05-native-wire
moedash
committed
ecaa55d
Pinned the delivery Core with a linked channel addressed by execution.
moedash
committed
7516568
Merge branch 'moe/AI-198-streams-provider-workflow-streams' into moe/AI-198-streams-provider-nexus
moedash
committed
b110ed0
Registered the stream consumer by execution.
moedash
committed
c85be89
Carried one execution field on the channel inputs.
moedash
committed
7cd9b3a
Merge branch 'moe/AI-198-py-03-workflow-runtime' into moe/AI-198-py-04-accessors
moedash
committed
4af0f93
Merge branch 'moe/AI-198-py-04-accessors' into moe/AI-198-streams-provider-workflow-streams
moedash
committed
0dce72e
Merge branch 'moe/AI-198-streams-provider-workflow-streams' into moe/AI-198-py-05-native-wire
moedash
committed
94aa0a8
Merge branch 'moe/AI-198-streams-provider-workflow-streams' into moe/AI-198-streams-provider-nexus
moedash
committed
5d31c9e
Merge branch 'moe/AI-198-py-05-native-wire' into moe/AI-198-py-06-native-provider
moedash
committed
f97af15
Named a standalone activity's stream channel by execution on the native cases.
moedash
committed
56ab511
Merge branch 'moe/AI-198-py-06-native-provider' into moe/AI-198-py-07-native-replay
moedash
committed
c2aba51
Merge commit 'c2aba51e9d88d7c27571504d9c451fb63c65e2fd' into moe/AI-198-streams-all
moedash
committed
8afd292
Merge commit '5d31c9ee994f4175bb4e0175ae88f5ebfbd6ecc0' into moe/AI-198-streams-all
moedash
committed
f7d6be0
Merge commit '7718b1ef273a5d80596a5fa53ee7e881cc4c8617' into moe/AI-198-streams-all
moedash
committed
aa4fe82
Pinned Core at the execution-addressed union head.
moedash
committed
df93277
Kept one copy of the client's channel owner resolver.
moedash
committed
611d772
Pinned Core at the protos that reuse the old numbers for execution.
moedash
committed
97ddcd8
Merge branch 'moe/AI-198-py-08-external-repairs' into moe/AI-198-py-09-external-interface
moedash
committed
e9ae44d
Pinned Core with the execution fields on their original numbers.
moedash
committed
d4022f6
Merge branch 'moe/AI-198-py-09-external-interface' into moe/AI-198-py-10-redis-provider
moedash
committed
01d9773
Merge branch 'moe/AI-198-py-01-protos' into moe/AI-198-py-02-streams-package
moedash
committed
cdeab8a
Merge branch 'moe/AI-198-py-02-streams-package' into moe/AI-198-py-03-workflow-runtime
moedash
committed
6a7f022
Merge branch 'moe/AI-198-py-03-workflow-runtime' into moe/AI-198-py-04-accessors
moedash
committed
44dfd4f
Merge branch 'moe/AI-198-py-04-accessors' into moe/AI-198-streams-provider-workflow-streams
moedash
committed
7ef8805
Merge branch 'moe/AI-198-streams-provider-workflow-streams' into moe/AI-198-py-05-native-wire
moedash
committed
7657155
Merge branch 'moe/AI-198-streams-provider-workflow-streams' into moe/AI-198-streams-provider-nexus
moedash
committed
995c4b4
Pinned the delivery Core with the execution fields on their original numbers.
moedash
committed
38aa617
Merge branch 'moe/AI-198-py-05-native-wire' into moe/AI-198-py-06-native-provider
moedash
committed
56bf209
Merge branch 'moe/AI-198-py-06-native-provider' into moe/AI-198-py-07-native-replay
moedash
committed
e473391
Merge commit 'e4733918f4ea525562fd47960a0ac698838e5bfd' into moe/AI-198-streams-all
moedash
committed
0686ca4
Merge commit '995c4b4bdf6bf38679770fc6252851083b99f555' into moe/AI-198-streams-all
moedash
committed
6012184
Merge commit '01d9773d9faeaa0798838c349cecefe90c6c721d' into moe/AI-198-streams-all
moedash
committed
30b6ad2
Pinned Core at the union head with the execution fields on their original numbers.
moedash
committed
0ddd6a2