The Dataflow non‑portable streaming worker’s StreamingCommitFinalizer currently caches bundle commit…
The Dataflow non‑portable streaming worker’s StreamingCommitFinalizer currently caches bundle commit…: a task in LegoFlow-SWE (Harbor dataset). Additionally, the non‑portable worker must start consuming and using the Windmill bundle‑finalization‑ID fields that the portable runner already…
The task
Additionally, the non‑portable worker must start consuming and using the Windmill bundle‑finalization‑ID fields that the portable runner already populates, so that expiration and duplicate detection are based on the correct identifiers.
Part of Lego-X/LegoFlow-SWE.