Adds bundleFinalizer support to Dataflow non-portable worker.#37723

Merged

scwhittle merged 17 commits into

apache:masterfrom

acrites:bundle-finalizer

Mar 20, 2026

Commits on Feb 26, 2026

Adds bundleFinalizer support to non-portable worker.
acrites
committed
Removes check preventing stateful DoFn's with bundle finalizers from running on Dataflow streaming non-portable worker.
acrites
committed

Commits on Feb 27, 2026

Changes finalize method to only acquire the lock once. Runs finalize callbacks in the given executor. This required changing tests since the callbacks are now running asynchronously.
acrites
committed

Commits on Mar 2, 2026

Addresses PR review comments, mostly around improving tests.
acrites
committed

Commits on Mar 6, 2026

Addresses more PR review comments. Triggering validates runner tests.
acrites
committed

Commits on Mar 9, 2026

Commits on Mar 13, 2026

Commits on Mar 16, 2026

Starts finalization callback cleanup thread lazily. This is for tests and pipelines that don't have any callbacks.
acrites
committed

Commits on Mar 17, 2026

Commits on Mar 18, 2026

Switches which Pair library being imported since it was causing undeclaredArtigfact build errors and fixes bug in ValidatesRunner streaming test which was not excluding all categories. Retriggering…
acrites
committed