You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by lc...@apache.org on 2020/01/06 17:01:52 UTC
[beam] branch master updated: [BEAM-9053] Improve error message
when unable to get the correct filesystem for specified path in Python SDK
This is an automated email from the ASF dual-hosted git repository.
lcwik 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 1172b8d [BEAM-9053] Improve error message when unable to get the correct filesystem for specified path in Python SDK
new 42dbb5d Merge pull request #10507 from dsdinter/python-io-error-msg
1172b8d is described below
commit 1172b8d437d2480c93d0a4ec6e5403888e8dd6cb
Author: David Sabater <da...@google.com>
AuthorDate: Mon Jan 6 14:09:44 2020 +0000
[BEAM-9053] Improve error message when unable to get the correct filesystem for specified path in Python SDK
---
sdks/python/apache_beam/io/filesystems.py | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
diff --git a/sdks/python/apache_beam/io/filesystems.py b/sdks/python/apache_beam/io/filesystems.py
index d8b3a4a..b41952f 100644
--- a/sdks/python/apache_beam/io/filesystems.py
+++ b/sdks/python/apache_beam/io/filesystems.py
@@ -89,7 +89,9 @@ class FileSystems(object):
systems = [fs for fs in FileSystem.get_all_subclasses()
if fs.scheme() == path_scheme]
if len(systems) == 0:
- raise ValueError('Unable to get the Filesystem for path %s' % path)
+ raise ValueError('Unable to get filesystem from specified path, please use the correct path '
+ 'or ensure the required dependency is installed, e.g., pip install apache_beam[gcp]. '
+ 'Path specified: %s' % path)
elif len(systems) == 1:
# Pipeline options could come either from the Pipeline itself (using
# direct runner), or via RuntimeValueProvider (other runners).