From 8f51910b87d63b373da307068686ec53dbd7d79b Mon Sep 17 00:00:00 2001 From: Shunping Huang Date: Mon, 5 Feb 2024 09:44:15 -0500 Subject: [PATCH] Replace get_bucket with bucket in _gcs_object --- sdks/python/apache_beam/io/gcp/gcsio.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/sdks/python/apache_beam/io/gcp/gcsio.py b/sdks/python/apache_beam/io/gcp/gcsio.py index 5a4bb91b0bad..b5a291428767 100644 --- a/sdks/python/apache_beam/io/gcp/gcsio.py +++ b/sdks/python/apache_beam/io/gcp/gcsio.py @@ -415,7 +415,7 @@ def _gcs_object(self, path): Returns: GCS object. """ bucket_name, blob_name = parse_gcs_path(path) - bucket = self.client.get_bucket(bucket_name) + bucket = self.client.bucket(bucket_name) blob = bucket.get_blob(blob_name) if blob: return blob