This is an automated email from the ASF dual-hosted git repository. damccorm pushed a commit to branch users/damccorm/nondeterminism in repository https://gitbox.apache.org/repos/asf/beam.git
commit 52450a814bc454bd2e91d05458bc10ebd056fda5 Author: Danny McCormick <[email protected]> AuthorDate: Mon Nov 11 12:26:24 2024 -0500 Remove nondeterminism from expansion tests --- sdks/python/apache_beam/transforms/external_test.py | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/sdks/python/apache_beam/transforms/external_test.py b/sdks/python/apache_beam/transforms/external_test.py index fe2914a0869..c95a5d19f0c 100644 --- a/sdks/python/apache_beam/transforms/external_test.py +++ b/sdks/python/apache_beam/transforms/external_test.py @@ -52,6 +52,7 @@ from apache_beam.typehints import typehints from apache_beam.typehints.native_type_compatibility import convert_to_beam_type from apache_beam.utils import proto_utils from apache_beam.utils.subprocess_server import JavaJarServer +from apache_beam.utils.subprocess_server import SubprocessServer # Protect against environments where apitools library is not available. # pylint: disable=wrong-import-order, wrong-import-position @@ -718,6 +719,9 @@ class JavaClassLookupPayloadBuilderTest(unittest.TestCase): class JavaJarExpansionServiceTest(unittest.TestCase): + def setUp(self): + SubprocessServer._cache._live_owners = set() + def test_classpath(self): with tempfile.TemporaryDirectory() as temp_dir: try:
