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..2a8d025e5b4f 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,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='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()