Skip to content

Commit 570eccf

Browse files
committed
chore: additional linting updates
1 parent bb455ff commit 570eccf

2 files changed

Lines changed: 8 additions & 2 deletions

File tree

packages/google-cloud-storage/google/cloud/storage/asyncio/async_multi_range_downloader.py

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -258,6 +258,7 @@ async def open(
258258
raise ValueError("Underlying bidi-gRPC stream is already open")
259259

260260
if retry_policy is None:
261+
261262
def on_error_wrapper(exc):
262263
self._open_retries += 1
263264
self._on_open_error(exc)

packages/google-cloud-storage/tests/system/test_zonal.py

Lines changed: 7 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -104,7 +104,9 @@ async def _run():
104104
object_data = os.urandom(object_size)
105105
object_checksum = google_crc32c.value(object_data)
106106

107-
writer = AsyncAppendableObjectWriter(grpc_client, _CROSS_REGION_BUCKET, object_name)
107+
writer = AsyncAppendableObjectWriter(
108+
grpc_client, _CROSS_REGION_BUCKET, object_name
109+
)
108110
await writer.open()
109111
await writer.append(object_data)
110112
object_metadata = await writer.close(finalize_on_close=True)
@@ -122,12 +124,15 @@ async def _run():
122124
assert buffer.getvalue() == object_data
123125

124126
# Clean up; use json client (i.e. `storage_client` fixture) to delete.
125-
blobs_to_delete.append(storage_client.bucket(_CROSS_REGION_BUCKET).blob(object_name))
127+
blobs_to_delete.append(
128+
storage_client.bucket(_CROSS_REGION_BUCKET).blob(object_name)
129+
)
126130
del writer
127131
gc.collect()
128132

129133
event_loop.run_until_complete(_run())
130134

135+
131136
@pytest.mark.parametrize(
132137
"object_size",
133138
[

0 commit comments

Comments
 (0)