Skip to content

Commit

Permalink
Replace get_bucket with bucket in _gcs_object
Browse files Browse the repository at this point in the history
  • Loading branch information
shunping committed Feb 5, 2024
1 parent d7f7b43 commit 8f51910
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion sdks/python/apache_beam/io/gcp/gcsio.py
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down

0 comments on commit 8f51910

Please sign in to comment.