From 29c91e087c66dc440f9a58e6d3e202a79e5293bf Mon Sep 17 00:00:00 2001 From: Danny McCormick Date: Wed, 4 Feb 2026 16:24:51 -0500 Subject: [PATCH 1/2] Use 'to_retain' tag for MultiProcessShared test --- sdks/python/apache_beam/utils/multi_process_shared_test.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/sdks/python/apache_beam/utils/multi_process_shared_test.py b/sdks/python/apache_beam/utils/multi_process_shared_test.py index 7b2b11857bfd..a1e2584f3516 100644 --- a/sdks/python/apache_beam/utils/multi_process_shared_test.py +++ b/sdks/python/apache_beam/utils/multi_process_shared_test.py @@ -289,6 +289,7 @@ def setUp(self): for tag in ['basic', 'main', 'to_delete', + 'to_retain', 'mix1', 'mix2', 'test_process_exit', @@ -323,7 +324,7 @@ def test_unsafe_hard_delete_autoproxywrapper(self): shared2 = multi_process_shared.MultiProcessShared( Counter, tag='to_delete', always_proxy=True, spawn_process=True) counter3 = multi_process_shared.MultiProcessShared( - Counter, tag='basic', always_proxy=True, spawn_process=True).acquire() + Counter, tag='to_retain', always_proxy=True, spawn_process=True).acquire() counter1 = shared1.acquire() counter2 = shared2.acquire() From aa00ddc14ce32c6835c963f991e92ea120abbee5 Mon Sep 17 00:00:00 2001 From: Danny McCormick Date: Wed, 4 Feb 2026 16:45:51 -0500 Subject: [PATCH 2/2] fmt --- sdks/python/apache_beam/utils/multi_process_shared_test.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/sdks/python/apache_beam/utils/multi_process_shared_test.py b/sdks/python/apache_beam/utils/multi_process_shared_test.py index a1e2584f3516..2a8d025e5b4f 100644 --- a/sdks/python/apache_beam/utils/multi_process_shared_test.py +++ b/sdks/python/apache_beam/utils/multi_process_shared_test.py @@ -324,7 +324,8 @@ def test_unsafe_hard_delete_autoproxywrapper(self): shared2 = multi_process_shared.MultiProcessShared( Counter, tag='to_delete', always_proxy=True, spawn_process=True) counter3 = multi_process_shared.MultiProcessShared( - Counter, tag='to_retain', always_proxy=True, spawn_process=True).acquire() + Counter, tag='to_retain', always_proxy=True, + spawn_process=True).acquire() counter1 = shared1.acquire() counter2 = shared2.acquire()