Stream lookahead: concurrent remote/API step execution for video workflows (10-12x FPS, outputs identical to sequential) - #2623

Open

balthazur wants to merge 16 commits into

mainfrom

poc/remote-workflow-stream-pipelining

Commits on Jul 7, 2026

Add remote stream pipelining for workflow video processing

balthazur
and
claude
committed
4ea7fb0
Extract reusable remote stream pipeline state machine

balthazur
and
claude
committed
379114f
Add ordering-correctness tests for remote stream pipelining

balthazur
and
claude
committed
c0d6bac

Commits on Jul 8, 2026

Extend remote stream pipelining to SAM3 and multi-model workflows

balthazur
and
claude
committed
9bcc5e0
Generalize remote pipelining into a stream-lookahead frontier scheduler

balthazur
and
claude
committed
27b3b58
Harden stream lookahead from adversarial and convention review

balthazur
and
claude
committed
d0cd67b
Generalize stream lookahead: engine offloads any declared async step

balthazur
and
claude
committed
df73c42
Point benchmark scripts at the renamed lookahead depth variable

balthazur
and
claude
committed
4310864
Pin overhead benchmark to production log level

balthazur
and
claude
committed
a5d5935
Apply black formatting to the stream workflow handlers

balthazur
and
claude
committed
749f10f
Address adversarial review: drain error propagation, async step context, usage timing, daemon workers

balthazur
and
claude
committed
d2f4a36
Copy class_names before mutation in SAM3 v1/v2 and seg_preview

balthazur
and
claude
committed
7b4801a
Make lookahead pool exit-safe for real and fail batch violations at the model step

balthazur
and
claude
committed
1e86fa6
Add EE version companions and executor GC fallback per repo review skills

balthazur
and
claude
committed
0cf9194
Key buffered stream dispatch on the actual handler, not the depth env var

balthazur
and
claude
committed
f906bd3
Add registry-wide adoption-safety guards + pin exit-safety internals

balthazur
and
claude
committed
6f79581