fix lint errors

Author: Pulkit0110

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

@@ -19,8 +19,11 @@
 from google.cloud.storage._experimental.asyncio.retry.base_strategy import (
     _BaseResumptionStrategy,
 )
+
+
 class _BidiStreamRetryManager:
     """Manages the generic retry loop for a bidi streaming operation."""
+
     def __init__(
         self,
         strategy: _BaseResumptionStrategy,
@@ -34,6 +37,7 @@ def __init__(
         """
         self._strategy = strategy
         self._stream_opener = stream_opener
+
     async def execute(self, initial_state: Any, retry_policy):
         """
         Executes the bidi operation with the configured retry policy.

tests/unit/asyncio/retry/test_bidi_stream_retry_manager.py

@@ -19,13 +19,16 @@
 from google.api_core import exceptions
 from google.api_core.retry_async import AsyncRetry
 
-from google.cloud.storage._experimental.asyncio.retry import bidi_stream_retry_manager as manager
+from google.cloud.storage._experimental.asyncio.retry import (
+    bidi_stream_retry_manager as manager,
+)
 from google.cloud.storage._experimental.asyncio.retry import base_strategy
 
 
 def _is_retriable(exc):
     return isinstance(exc, exceptions.ServiceUnavailable)
 
+
 DEFAULT_TEST_RETRY = AsyncRetry(predicate=_is_retriable, deadline=1)
 
 
@@ -147,6 +150,8 @@ async def mock_stream_opener(*args, **kwargs):
             strategy=mock_strategy, stream_opener=mock_stream_opener
         )
         with pytest.raises(exceptions.PermissionDenied):
-            await retry_manager.execute(initial_state={}, retry_policy=DEFAULT_TEST_RETRY)
+            await retry_manager.execute(
+                initial_state={}, retry_policy=DEFAULT_TEST_RETRY
+            )
 
         mock_strategy.recover_state_on_failure.assert_not_called()