[ULTRA EXPERIMENTAL — DO NOT REVIEW] Durable workflows exploration - #6912

Draft

Alek99 wants to merge 121 commits into

mainfrom

alek/workflows-mvp

Commits on Aug 18, 2026

Add Reflex Workflows MVP slice: durable events, kernel, and test harness
Alek99
committed
e60fb75
Fence workflow claims with renewable leases
Alek99
committed
9c576d8
Make workflow retries mean what they say
Alek99
committed
cfccb5a
Stop redeploys from stranding in-flight workflow runs
Alek99
committed
3ed7ecc
Reject handler bodies that silently break durability
Alek99
committed
34d8caf
Add run listing and label filtering
Alek99
committed
d55c9ba
Serve webhook-triggered workflow roots over HTTP
Alek99
committed
ce7aea1
Fire cron schedule triggers
Alek99
committed
3586943
Add durable waits and typed signals
Alek99
committed
91a75c2
Add an end-to-end test covering the whole workflow surface
Alek99
committed
6fbb731
Document workflows
Alek99
committed
b5c0fe0
Add parallel fan-out with child runs and joins
Alek99
committed
9914990
Add start policies: singleton, debounce, rate limit, throttle
Alek99
committed
7bf839c
Ship the RunStore contract as runnable checks
Alek99
committed
2b36be4
Add the reflex workflows CLI
Alek99
committed
f6b88bc
Add a workflow observer hook
Alek99
committed
5f18842
Fix three defects found by adversarial audit
Alek99
committed
ac6ade3
Fix four defects a deeper audit reproduced
Alek99
committed
a7c0b15
Run every workflow test against the durable store too
Alek99
committed
68bc1d8
Fix six more audit findings
Alek99
committed
ab9cecd
Abandon a lease that cannot be renewed, and gate fan-out branches
Alek99
committed
ef18d09
Bound SQLite contention so it cannot freeze the app
Alek99
committed
560c9e3

Commits on Aug 19, 2026

Run workflow attempts concurrently
Alek99
committed
5d3cb73
Race parallel branches with mode="first"
Alek99
committed
6716046
Space a throttled backlog instead of bunching it
Alek99
committed
386a5fc
Add a Postgres run store, and run the suite against it
Alek99
committed
5692517
Approve from an email: signed links plus a per-attempt run context
Alek99
committed
8940546
Record substeps with rx.step, and route steps to worker queues
Alek99
committed
83a3e96
Run SQLite store calls on a worker thread
Alek99
committed
2f40a7e
Let policy keys reach into model payloads; let the harness start any root
Alek99
committed
37892e8
Add reflex workflows check, the generation-loop validator
Alek99
committed
fed56ec
Close the Postgres test fixture's pool on the loop that opened it
Alek99
committed
6c7d5f8
Never swallow a task's own cancellation while releasing a lease
Alek99
committed
5c2de07
Resolve the workflow store from the deployment's environment
Alek99
committed
5b7c53a
Prove the engine inside a real server with integration tests
Alek99
committed
1f758a8
Resolve dotted check targets from the project root
Alek99
committed
21a98b4
Run the workflow integration tests in prod mode too
Alek99
committed
ef82d7f
Freeze the execution contract, and close the two gaps it exposed
Alek99
committed
fc0716f
Add the operator actions the contract promises
Alek99
committed
5085113
Add a headless worker: reflex workflows worker
Alek99
committed
073968e
Add a metrics observer for the numbers a deployment alerts on
Alek99
committed
a2309de
Never let a schedule cursor move backwards
Alek99
committed
ef2113e
Tell a worker's operator why their workflows will not load
Alek99
committed
827f9a9
State the one rule rx.step puts on your code
Alek99
committed
4d46b23
Make every terminal path deliver its arrival atomically
Alek99
committed
eb8dd63
Pin two more contract clauses with conformance checks
Alek99
committed
3ed4b28
Pin the compiler guards a generator hits first
Alek99
committed
b78da78
Fix force_complete and force_fail raising NameError from rx.workflows
Alek99
committed
b785e3c
Make the type-only-import bug class impossible to ship again
Alek99
committed
518004c
Have the worker name the workflows it cannot start
Alek99
committed
5554dd6
Refuse an approval token that can never expire
Alek99
committed
c11823e
Refuse a webhook body that cannot fill the root's parameters
Alek99
committed
60dd7ad
Refuse run state that JSON cannot represent
Alek99
committed
6e987e5
Assert the scheduling predicates directly
Alek99
committed
48cee24
Write down the runtime's lifecycle rules
Alek99
committed
d925e85
Validate the instrument the whole suite measures with
Alek99
committed
ee56d1d
Add the skip operator action
Alek99
committed
049941b
Enforce a singleton's limit inside the admitting transaction
Alek99
committed
659446e
Walk the crash matrix as a conformance check
Alek99
committed
74e76d4
Add reflex workflows dev and a typed run handle
Alek99
committed
30466f0
Scaffold a runnable workflow with reflex workflows init
Alek99
committed
44b3fc4
Add an authenticated HTTP API for starting and reading runs
Alek99
committed
fadaaf8
Document tenancy and who runs the workers
Alek99
committed
03f1b20
Show what starts each workflow with reflex workflows triggers
Alek99
committed
a4017df
Cover the wait's crash and delivery-refusal semantics
Alek99
committed
0d23a36
workflows: add a preflight doctor for deployment configuration
Alek99
committed
7f50286
workflows: make the dev loop show what a durable run is doing
Alek99
committed
96ec413
workflows: report attempts an operator would recognize
Alek99
committed
64746e9
workflows: drain a stopping worker instead of dropping its attempts
Alek99
committed
d9d000e
workflows: take the drain budget from the deployment
Alek99
committed
548ebbc
workflows: let a process start runs without becoming a worker
Alek99
committed
2ae6773
workflows: answer 'is this healthy' without opening the database
Alek99
committed
9d5b9f3
workflows: make a process's counters scrapeable
Alek99
committed
c6216fa
workflows: finish the operator actions on the command line
Alek99
committed
e421ef8
workflows: stop retrying code bugs, and make a release's runs findable
Alek99
committed
752511b
workflows: document the failures that are not crashes, and pin them
Alek99
committed
3eaa987
workflows: fix client isolation, store leaks, and admission binding
Alek99
committed
9fa81ab
workflows: hand join results over in declaration order
Alek99
committed
f4c102e
workflows: turn the two open report defects into executable specs
Alek99
committed
ce4f51f
workflows: make one approval's choices mutually exclusive
Alek99
committed
1359a84
workflows: say what losing a race does not protect you from
Alek99
committed
c234309
workflows: close the two gaps the second review found
Alek99
committed
59c7b89
workflows: stop a cancelled parent from cancelling its branches
Alek99
committed
94152c9
workflows: pin the retry-loses-the-chain defect as a spec
Alek99
committed
a82d099
workflows: scope webhook dedupe keys to the root they start
Alek99
committed
890b0ed
workflows: scope the legacy webhook key lookup to the same root
Alek99
committed
a3228a1
workflows: make start policies atomic across processes
Alek99
committed
7b25195
workflows: retry and skip restore the chain the failure tombstoned
Alek99
committed
a188b42
workflows: answer SQLite scheduling from an index, not a Python loop
Alek99
committed
d115684
workflows: give webhook identity the shapes providers actually use
Alek99
committed
3bcabd4
workflows: close the review's operability batch
Alek99
committed
fef3f88
workflows: accept GitHub's form-encoded webhook mode
Alek99
committed
10f08b1
workflows: fix what the adversarial review of tonight's fixes found
Alek99
committed
7130537
workflows: say that operator repair overrides start policies
Alek99
committed
208b607
workflows: a duplicate admission must leave with zero side effects
Alek99
committed
4b413ae
workflows: durations must be finite
Alek99
committed
e67ee05

Commits on Aug 20, 2026

workflows: workers on the default clock derive time from the store
Alek99
committed
53b05fd
workflows: fence run deadlines at the store, in both directions
Alek99
committed
7b6001e
workflows: close the bounded time edges
Alek99
committed
8757199
workflows: refuse lossy run data, type-check the HTTP boundary
Alek99
committed
738e54b
workflows: branches close with their parent
Alek99
committed
5843481
workflows: operator-action helpers on the test harness
Alek99
committed
dc9c79a
workflows: say where release pinning belongs
Alek99
committed
0ce143c
workflows: kill a real worker at real boundaries
Alek99
committed
53779a3
workflows: make the contract's vocabulary complete and self-checking
Alek99
committed
e5e80ba
workflows: typed run results, and run-id prefixes in the CLI
Alek99
committed
399277b
workflows: an OpenTelemetry observer
Alek99
committed
9f02f27
workflows: audit composition against the graduation dimensions
Alek99
committed
20273f6
workflows: stop reflex deploy misdirecting a workflow-only project
Alek99
committed
fab1232
workflows: three Postgres blockers from the review
Alek99
committed
c9d0948
workflows: the rest of the review's findings
Alek99
committed
439c425
workflows: second review round
Alek99
committed
45ba1c7

Commits on Aug 22, 2026

workflows: terminal transitions close completely, everywhere
Alek99
committed
be95a02

Commits on Aug 24, 2026

workflows: one validation semantics at every boundary
Alek99
committed
71cdc92
workflows: reflex workflows serve -- the standalone service
Alek99
committed
994a33b
workflows: business-key addressing for runs and signals
Alek99
committed
47d369a

Commits on Aug 25, 2026

workflows: the channel inbox -- durable correlated delivery
Alek99
committed
16349de
workflows: correlated webhook-to-signal delivery, end to end
Alek99
committed
ab179d5
workflows: competitor-pattern parity suite
Alek99
committed
5b5ed50
workflows: release-pinned execution and the worker fleet
Alek99
committed
d464bb9
workflows: operator mutations record who asked and why
Alek99
committed
08897b5