[BEAM-8649] Eat stderr from subprocess in _get_default_gcp_region
diff --git a/sdks/python/apache_beam/options/pipeline_options.py b/sdks/python/apache_beam/options/pipeline_options.py
index 5ade96f..898603e 100644
--- a/sdks/python/apache_beam/options/pipeline_options.py
+++ b/sdks/python/apache_beam/options/pipeline_options.py
@@ -23,6 +23,7 @@
import json
import logging
import os
+import subprocess
from builtins import list
from builtins import object
@@ -514,11 +515,12 @@
return environment_region
try:
cmd = ['gcloud', 'config', 'get-value', 'compute/region']
- output = processes.check_output(cmd).decode('utf-8').strip()
- if output:
+ raw_output = processes.check_output(cmd, stderr=subprocess.DEVNULL)
+ formatted_output = raw_output.decode('utf-8').strip()
+ if formatted_output:
logging.info('Using default GCP region %s from `%s`',
- output, ' '.join(cmd))
- return output
+ formatted_output, ' '.join(cmd))
+ return formatted_output
except RuntimeError:
pass
logging.warning(
