File tree Expand file tree Collapse file tree 1 file changed +2
-2
lines changed
sdks/python/apache_beam/transforms Expand file tree Collapse file tree 1 file changed +2
-2
lines changed Original file line number Diff line number Diff line change @@ -656,8 +656,6 @@ class JavaJarExpansionService(object):
656656 transform.
657657 """
658658 def __init__ (self , path_to_jar , extra_args = None ):
659- if extra_args is None :
660- extra_args = ['{{PORT}}' , f'--filesToStage={ path_to_jar } ' ]
661659 self ._path_to_jar = path_to_jar
662660 self ._extra_args = extra_args
663661 self ._service_count = 0
@@ -666,6 +664,8 @@ def __enter__(self):
666664 if self ._service_count == 0 :
667665 self ._path_to_jar = subprocess_server .JavaJarServer .local_jar (
668666 self ._path_to_jar )
667+ if self ._extra_args is None :
668+ self ._extra_args = ['{{PORT}}' , f'--filesToStage={ self ._path_to_jar } ' ]
669669 # Consider memoizing these servers (with some timeout).
670670 self ._service_provider = subprocess_server .JavaJarServer (
671671 ExpansionAndArtifactRetrievalStub ,
You can’t perform that action at this time.
0 commit comments