chore: format _stream_multiplexer.py and test_zonal.py

Author: zhixiangli

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

@@ -87,7 +87,9 @@ def _get_unique_queues(self) -> Set[asyncio.Queue]:
 
     async def _put_with_timeout(self, queue: asyncio.Queue, item) -> None:
         try:
-            await asyncio.wait_for(queue.put(item), timeout=_DEFAULT_PUT_TIMEOUT_SECONDS)
+            await asyncio.wait_for(
+                queue.put(item), timeout=_DEFAULT_PUT_TIMEOUT_SECONDS
+            )
         except asyncio.TimeoutError:
             if queue not in self._get_unique_queues():
                 logger.debug("Dropped item for unregistered queue.")

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

@@ -669,9 +669,7 @@ async def _run():
 
         del writer
         gc.collect()
-        blobs_to_delete.append(
-            storage_client.bucket(_ZONAL_BUCKET).blob(object_name)
-        )
+        blobs_to_delete.append(storage_client.bucket(_ZONAL_BUCKET).blob(object_name))
 
     event_loop.run_until_complete(_run())
 
@@ -690,7 +688,9 @@ def test_mrd_concurrent_download_cancellation(
     async def _run():
         object_data = os.urandom(object_size)
 
-        writer = AsyncAppendableObjectWriter(grpc_client_direct, _ZONAL_BUCKET, object_name)
+        writer = AsyncAppendableObjectWriter(
+            grpc_client_direct, _ZONAL_BUCKET, object_name
+        )
         await writer.open()
         await writer.append(object_data)
         await writer.close(finalize_on_close=True)
@@ -749,7 +749,9 @@ def test_mrd_concurrent_download_out_of_bounds(
     async def _run():
         object_data = os.urandom(object_size)
 
-        writer = AsyncAppendableObjectWriter(grpc_client_direct, _ZONAL_BUCKET, object_name)
+        writer = AsyncAppendableObjectWriter(
+            grpc_client_direct, _ZONAL_BUCKET, object_name
+        )
         await writer.open()
         await writer.append(object_data)
         await writer.close(finalize_on_close=True)