Add support for streaming - #157

Merged

joefreeman merged 35 commits into

mainfrom

Aug 30, 2026

Commits on Apr 18, 2026

Setup tables for streams
joefreeman
committed
9d7f4bf
Setup streams module
joefreeman
committed
d43bcf4
Close streams when execution completes
joefreeman
committed
ab58549
Update wire protocol
joefreeman
committed
326328b
Implement generator detector and driver
joefreeman
committed
aba392e
Setup stream consumers
joefreeman
committed
24ddfc1
Update topic, and update epoch generation
joefreeman
committed
6afcba2
Add serialiser for stream
joefreeman
committed
e87ab2f
Fix typing
joefreeman
committed
b340d49
Add tests
joefreeman
committed
f2b3f4d

Commits on Apr 19, 2026

Various fixes
joefreeman
committed
5d8d86c
Add stream topic
joefreeman
committed
9870be5
Tidy stream IDs/terminology
joefreeman
committed
90d5b6f
Support configuring buffer/backpressure
joefreeman
committed
589612b
Use completions to determine execution state
joefreeman
committed
4932cb3
Consolidate stream filters into a computed stride
joefreeman
committed
aecdb71

Commits on Apr 20, 2026

Commits on Apr 21, 2026

Dispatch worker requests async
joefreeman
committed
982d75c
Don't use memoised execution with errored/timed-out stream
joefreeman
committed
9dd66db

Commits on Apr 22, 2026

Track stream dependencies
joefreeman
committed
d007aa0

Commits on May 17, 2026

Merge branch 'main' into streaming
joefreeman
committed
95a5221

Commits on Jun 19, 2026

Fix issues
joefreeman
committed
aba6c91

Commits on Aug 29, 2026

Acknowledge stream consumption
joefreeman
committed
96e58b4
Release abandoned stream subscriptions
joefreeman
committed
c41135a

Commits on Aug 30, 2026

Have worker error if workflows can't be loaded
joefreeman
committed
20031f9
Support async stream iterators
joefreeman
committed
4c69a64
Update workflow topic to expose run statuses
joefreeman
committed
d94f782
Format/lint
joefreeman
committed
37cc013
More format/lint
joefreeman
committed
883c7ab
Fix test
joefreeman
committed
4477e27