From 7f540359b73c738a4720b553340d497dcfc176f0 Mon Sep 17 00:00:00 2001 From: Steven van Rossum Date: Wed, 12 Oct 2022 19:28:12 +0200 Subject: [PATCH] Fix typo in bootstrap_beam_venv.py (#23574) --- .../beam/sdk/extensions/python/bootstrap_beam_venv.py | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/sdks/java/extensions/python/src/main/resources/org/apache/beam/sdk/extensions/python/bootstrap_beam_venv.py b/sdks/java/extensions/python/src/main/resources/org/apache/beam/sdk/extensions/python/bootstrap_beam_venv.py index 54aeb6a1ee328..3d4a519a96f9b 100644 --- a/sdks/java/extensions/python/src/main/resources/org/apache/beam/sdk/extensions/python/bootstrap_beam_venv.py +++ b/sdks/java/extensions/python/src/main/resources/org/apache/beam/sdk/extensions/python/bootstrap_beam_venv.py @@ -71,16 +71,16 @@ def maybe_strict_version(s): return parse_version('0.0') beam_version = max(info['releases'], key=maybe_strict_version) - beam_package = 'apache_beam[gcp,aws,asure,dataframe]==' + beam_version + beam_package = 'apache_beam[gcp,aws,azure,dataframe]==' + beam_version elif (os.path.exists(options.beam_version) or options.beam_version.startswith('http://') or options.beam_version.startswith('https://')): # It's a path to a tarball. beam_version = os.path.basename(options.beam_version) - beam_package = options.beam_version + '[gcp,aws,asure,dataframe]' + beam_package = options.beam_version + '[gcp,aws,azure,dataframe]' else: beam_version = options.beam_version - beam_package = 'apache_beam[gcp,aws,asure,dataframe]==' + beam_version + beam_package = 'apache_beam[gcp,aws,azure,dataframe]==' + beam_version deps = options.extra_packages.split(';') if options.extra_packages else [] venv_dir = os.path.join(