This is an automated email from the ASF dual-hosted git repository.
shunping 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 431cb560d7d Fix logic in lookup_blob to correctly return blob in
bucket (#35475)
431cb560d7d is described below
commit 431cb560d7d82c5e07bc2519780195d30695bf77
Author: Nhon Dinh <[email protected]>
AuthorDate: Mon Jun 30 20:47:34 2025 +0700
Fix logic in lookup_blob to correctly return blob in bucket (#35475)
Co-authored-by: Nhon Dinh <[email protected]>
---
sdks/python/apache_beam/io/gcp/gcsio_test.py | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git a/sdks/python/apache_beam/io/gcp/gcsio_test.py
b/sdks/python/apache_beam/io/gcp/gcsio_test.py
index 0f28425c1c0..4c18647729e 100644
--- a/sdks/python/apache_beam/io/gcp/gcsio_test.py
+++ b/sdks/python/apache_beam/io/gcp/gcsio_test.py
@@ -174,7 +174,8 @@ class FakeBucket(object):
if name in bucket.blobs:
return bucket.blobs[name]
else:
- return bucket.create_blob(name)
+ new_blob = bucket._create_blob(name)
+ return bucket.add_blob(new_blob)
def set_default_kms_key_name(self, name):
self.default_kms_key_name = name
