You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by bo...@apache.org on 2020/05/01 16:26:22 UTC

[beam] branch master updated: Guard grpc import.

This is an automated email from the ASF dual-hosted git repository.

boyuanz pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git


The following commit(s) were added to refs/heads/master by this push:
     new c7be705  Guard grpc import.
     new b78c7ed  Merge pull request #11587 from robertwb/no-grpc
c7be705 is described below

commit c7be7052ad11ff38c8bafab08614762404e2561e
Author: Robert Bradshaw <ro...@gmail.com>
AuthorDate: Thu Apr 30 22:47:14 2020 -0700

    Guard grpc import.
---
 sdks/python/apache_beam/utils/subprocess_server.py | 9 ++++++++-
 1 file changed, 8 insertions(+), 1 deletion(-)

diff --git a/sdks/python/apache_beam/utils/subprocess_server.py b/sdks/python/apache_beam/utils/subprocess_server.py
index 6d18769..92b60b5 100644
--- a/sdks/python/apache_beam/utils/subprocess_server.py
+++ b/sdks/python/apache_beam/utils/subprocess_server.py
@@ -31,12 +31,19 @@ import tempfile
 import threading
 import time
 
-import grpc
 from future.moves.urllib.error import URLError
 from future.moves.urllib.request import urlopen
 
 from apache_beam.version import __version__ as beam_version
 
+# Protect against environments where grpc is not available.
+# pylint: disable=wrong-import-order, wrong-import-position, ungrouped-imports
+try:
+  import grpc
+except ImportError:
+  grpc = None
+# pylint: enable=wrong-import-order, wrong-import-position, ungrouped-imports
+
 _LOGGER = logging.getLogger(__name__)