Fix gcsio.exists call
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/cead6457 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/cead6457 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/cead6457 Branch: refs/heads/python-sdk Commit: cead6457187963b9f62ce94d301c56b17510647e Parents: 436724e Author: Silviu Calinoiu <[email protected]> Authored: Wed Jun 29 12:07:59 2016 -0700 Committer: Silviu Calinoiu <[email protected]> Committed: Wed Jun 29 12:07:59 2016 -0700 ---------------------------------------------------------------------- sdks/python/apache_beam/io/fileio.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/cead6457/sdks/python/apache_beam/io/fileio.py ---------------------------------------------------------------------- diff --git a/sdks/python/apache_beam/io/fileio.py b/sdks/python/apache_beam/io/fileio.py index 115bc0e..6475a34 100644 --- a/sdks/python/apache_beam/io/fileio.py +++ b/sdks/python/apache_beam/io/fileio.py @@ -213,7 +213,7 @@ class ChannelFactory(object): if path.startswith('gs://'): # pylint: disable=wrong-import-order, wrong-import-position from apache_beam.io import gcsio - return gcsio.GcsIO().exists() + return gcsio.GcsIO().exists(path) else: return os.path.exists(path)
