Skip to content

Commit 31ca5e6

Browse files
committed
Handle NotFound exception in bucket deletion test
1 parent 6592016 commit 31ca5e6

File tree

1 file changed

+6
-1
lines changed

1 file changed

+6
-1
lines changed

sdks/python/apache_beam/io/gcp/gcsio_integration_test.py

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -242,7 +242,12 @@ def test_create_default_bucket(self, mock_default_gcs_bucket_name):
242242
# verify soft delete policy is disabled by default in the default bucket
243243
# after creation
244244
self.assertEqual(bucket.soft_delete_policy.retention_duration_seconds, 0)
245-
bucket.delete()
245+
existing_bucket = self.gcsio.get_bucket(overridden_bucket_name)
246+
if existing_bucket:
247+
try:
248+
existing_bucket.delete()
249+
except NotFound:
250+
pass
246251

247252
self.assertIsNone(self.gcsio.get_bucket(overridden_bucket_name))
248253

0 commit comments

Comments
 (0)