This is an automated email from the ASF dual-hosted git repository.
damccorm pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
The following commit(s) were added to refs/heads/master by this push:
new 97ae5aa8d70 Remove nondeterminism from expansion tests (#33082)
97ae5aa8d70 is described below
commit 97ae5aa8d70519921da761201c1e85113b5cdf26
Author: Danny McCormick <[email protected]>
AuthorDate: Mon Nov 11 13:42:25 2024 -0500
Remove nondeterminism from expansion tests (#33082)
---
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:
