diff --git a/sdks/python/apache_beam/io/fileio.py b/sdks/python/apache_beam/io/fileio.py index 115bc0ec9d0d0..6475a347f05f1 100644 --- a/sdks/python/apache_beam/io/fileio.py +++ b/sdks/python/apache_beam/io/fileio.py @@ -213,7 +213,7 @@ def exists(path): 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)