🦉 Updates from OwlBot post-processor

See https://github.com/googleapis/repo-automation-bots/blob/main/packages/owl-bot/README.md

Author: gcf-owl-bot[bot]

google/cloud/storage/_experimental/asyncio/retry/base_strategy.py

@@ -1,6 +1,7 @@
 import abc
 from typing import Any, Iterable
 
+
 class _BaseResumptionStrategy(abc.ABC):
     """Abstract base class defining the interface for a bidi stream resumption strategy.
 

google/cloud/storage/_experimental/asyncio/retry/reads_resumption_strategy.py

@@ -6,9 +6,13 @@
     _BaseResumptionStrategy,
 )
 
+
 class _DownloadState:
     """A helper class to track the state of a single range download."""
-    def __init__(self, initial_offset: int, initial_length: int, user_buffer: IO[bytes]):
+
+    def __init__(
+        self, initial_offset: int, initial_length: int, user_buffer: IO[bytes]
+    ):
         self.initial_offset = initial_offset
         self.initial_length = initial_length
         self.user_buffer = user_buffer
@@ -41,7 +45,9 @@ def generate_requests(self, state: dict) -> List[storage_v2.ReadRange]:
                 pending_requests.append(new_request)
         return pending_requests
 
-    def update_state_from_response(self, response: storage_v2.BidiReadObjectResponse, state: dict) -> None:
+    def update_state_from_response(
+        self, response: storage_v2.BidiReadObjectResponse, state: dict
+    ) -> None:
         """Processes a server response, performs integrity checks, and updates state."""
         for object_data_range in response.object_data_ranges:
             read_id = object_data_range.read_range.read_id
@@ -61,8 +67,13 @@ def update_state_from_response(self, response: storage_v2.BidiReadObjectResponse
             # Final Byte Count Verification
             if object_data_range.range_end:
                 read_state.is_complete = True
-                if read_state.initial_length != 0 and read_state.bytes_written != read_state.initial_length:
-                    raise DataCorruption(response, f"Byte count mismatch for read_id {read_id}")
+                if (
+                    read_state.initial_length != 0
+                    and read_state.bytes_written != read_state.initial_length
+                ):
+                    raise DataCorruption(
+                        response, f"Byte count mismatch for read_id {read_id}"
+                    )
 
     async def recover_state_on_failure(self, error: Exception, state: Any) -> None:
         """Handles BidiReadObjectRedirectError for reads."""

tests/unit/asyncio/retry/test_reads_resumption_strategy.py

@@ -105,7 +105,9 @@ def test_update_state_processes_single_chunk_successfully(self):
         response = storage_v2.BidiReadObjectResponse(
             object_data_ranges=[
                 storage_v2.types.ObjectRangeData(
-                    read_range=storage_v2.ReadRange(read_id=_READ_ID, read_offset=0, read_length=len(data)),
+                    read_range=storage_v2.ReadRange(
+                        read_id=_READ_ID, read_offset=0, read_length=len(data)
+                    ),
                     checksummed_data=storage_v2.ChecksummedData(content=data),
                 )
             ]
@@ -128,7 +130,9 @@ def test_update_state_from_response_offset_mismatch(self):
         response = storage_v2.BidiReadObjectResponse(
             object_data_ranges=[
                 storage_v2.types.ObjectRangeData(
-                    read_range=storage_v2.ReadRange(read_id=_READ_ID, read_offset=0, read_length=4),
+                    read_range=storage_v2.ReadRange(
+                        read_id=_READ_ID, read_offset=0, read_length=4
+                    ),
                     checksummed_data=storage_v2.ChecksummedData(content=b"data"),
                 )
             ]
@@ -147,7 +151,9 @@ def test_update_state_from_response_final_byte_count_mismatch(self):
         response = storage_v2.BidiReadObjectResponse(
             object_data_ranges=[
                 storage_v2.types.ObjectRangeData(
-                    read_range=storage_v2.ReadRange(read_id=_READ_ID, read_offset=0, read_length=4),
+                    read_range=storage_v2.ReadRange(
+                        read_id=_READ_ID, read_offset=0, read_length=4
+                    ),
                     checksummed_data=storage_v2.ChecksummedData(content=b"data"),
                     range_end=True,
                 )
@@ -169,7 +175,9 @@ def test_update_state_from_response_completes_download(self):
         response = storage_v2.BidiReadObjectResponse(
             object_data_ranges=[
                 storage_v2.types.ObjectRangeData(
-                    read_range=storage_v2.ReadRange(read_id=_READ_ID, read_offset=0, read_length=len(data)),
+                    read_range=storage_v2.ReadRange(
+                        read_id=_READ_ID, read_offset=0, read_length=len(data)
+                    ),
                     checksummed_data=storage_v2.ChecksummedData(content=data),
                     range_end=True,
                 )
@@ -193,7 +201,9 @@ def test_update_state_from_response_completes_download_zero_length(self):
         response = storage_v2.BidiReadObjectResponse(
             object_data_ranges=[
                 storage_v2.types.ObjectRangeData(
-                    read_range=storage_v2.ReadRange(read_id=_READ_ID, read_offset=0, read_length=len(data)),
+                    read_range=storage_v2.ReadRange(
+                        read_id=_READ_ID, read_offset=0, read_length=len(data)
+                    ),
                     checksummed_data=storage_v2.ChecksummedData(content=data),
                     range_end=True,
                 )