Skip to content

Commit 2b0112c

Browse files
committed
minor changes
1 parent e0f06a5 commit 2b0112c

File tree

2 files changed

+7
-1
lines changed

2 files changed

+7
-1
lines changed
Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -164,6 +164,12 @@ async def write_req_gen():
164164
finally:
165165
# Clean up the test bucket.
166166
try:
167+
delete_object_req = storage_v2.DeleteObjectRequest(
168+
bucket="projects/_/buckets/" + bucket_name,
169+
object=object_name
170+
)
171+
await gapic_client.delete_object(request=delete_object_req)
172+
167173
delete_bucket_req = storage_v2.DeleteBucketRequest(name=f"projects/_/buckets/{bucket_name}")
168174
await gapic_client.delete_bucket(request=delete_bucket_req)
169175
except Exception as e:

tests/unit/asyncio/retry/test_reads_resumption_strategy.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -221,7 +221,7 @@ def test_update_state_captures_read_handle(self):
221221
response = self._create_response(b"data", _READ_ID, 0, handle=new_handle)
222222

223223
self.strategy.update_state_from_response(response, self.state)
224-
self.assertEqual(self.state["read_handle"], new_handle)
224+
self.assertEqual(self.state["read_handle"].handle, new_handle)
225225

226226
def test_update_state_unknown_id(self):
227227
"""Verify we ignore data for IDs not in our tracking state."""

0 commit comments

Comments
 (0)