This is an automated email from the ASF dual-hosted git repository.
ibzib pushed a commit to branch release-2.34.0
in repository https://gitbox.apache.org/repos/asf/beam.git
The following commit(s) were added to refs/heads/release-2.34.0 by this push:
new c3e6521 Merge pull request #15891: [BEAM-13187] Set filesToStage
after full jar resolution.
new 7e777d8 Merge pull request #15902 from TheNeuralBit/BEAM-13187-cp
c3e6521 is described below
commit c3e6521e4aa867c4ee2df81133cef24aedb66704
Author: Chamikara Jayalath <[email protected]>
AuthorDate: Thu Nov 4 10:22:18 2021 -0700
Merge pull request #15891: [BEAM-13187] Set filesToStage after full jar
resolution.
---
sdks/python/apache_beam/transforms/external.py | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/sdks/python/apache_beam/transforms/external.py
b/sdks/python/apache_beam/transforms/external.py
index ab02ae6..008b076 100644
--- a/sdks/python/apache_beam/transforms/external.py
+++ b/sdks/python/apache_beam/transforms/external.py
@@ -656,8 +656,6 @@ class JavaJarExpansionService(object):
transform.
"""
def __init__(self, path_to_jar, extra_args=None):
- if extra_args is None:
- extra_args = ['{{PORT}}', f'--filesToStage={path_to_jar}']
self._path_to_jar = path_to_jar
self._extra_args = extra_args
self._service_count = 0
@@ -666,6 +664,8 @@ class JavaJarExpansionService(object):
if self._service_count == 0:
self._path_to_jar = subprocess_server.JavaJarServer.local_jar(
self._path_to_jar)
+ if self._extra_args is None:
+ self._extra_args = ['{{PORT}}', f'--filesToStage={self._path_to_jar}']
# Consider memoizing these servers (with some timeout).
self._service_provider = subprocess_server.JavaJarServer(
ExpansionAndArtifactRetrievalStub,
