Skip to content

Commit

Permalink
Use empty flags for default expansion service options. (apache#30858)
Browse files Browse the repository at this point in the history
The cli-invoking variant already parses and passes these in manually.
Internal uses should not automatically pick up sys.argv.
  • Loading branch information
robertwb authored Apr 4, 2024
1 parent 0d41168 commit 6c280c6
Showing 1 changed file with 3 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -40,7 +40,9 @@ class ExpansionServiceServicer(
beam_expansion_api_pb2_grpc.ExpansionServiceServicer):
def __init__(self, options=None, loopback_address=None):
self._options = options or beam_pipeline.PipelineOptions(
environment_type=python_urns.EMBEDDED_PYTHON, sdk_location='container')
flags=[],
environment_type=python_urns.EMBEDDED_PYTHON,
sdk_location='container')
default_environment = (environments.Environment.from_options(self._options))
if loopback_address:
loopback_environment = environments.Environment.from_options(
Expand Down

0 comments on commit 6c280c6

Please sign in to comment.