style: apply black formatting to test_async_appendable_object_writer.py

Author: sahusneha2004

packages/google-cloud-storage/tests/unit/asyncio/test_async_appendable_object_writer.py

@@ -195,9 +195,9 @@ async def test_state_lookup(self, mock_appendable_writer):
         writer._is_stream_open = True
         writer.write_obj_stream = mock_appendable_writer["mock_stream"]
 
-        mock_appendable_writer[
-            "mock_stream"
-        ].recv.return_value = storage_type.BidiWriteObjectResponse(persisted_size=100)
+        mock_appendable_writer["mock_stream"].recv.return_value = (
+            storage_type.BidiWriteObjectResponse(persisted_size=100)
+        )
 
         size = await writer.state_lookup()
 
@@ -431,9 +431,9 @@ async def test_flush_resets_counters(self, mock_appendable_writer):
         writer.write_obj_stream = mock_appendable_writer["mock_stream"]
         writer.bytes_appended_since_last_flush = 100
 
-        mock_appendable_writer[
-            "mock_stream"
-        ].recv.return_value = storage_type.BidiWriteObjectResponse(persisted_size=200)
+        mock_appendable_writer["mock_stream"].recv.return_value = (
+            storage_type.BidiWriteObjectResponse(persisted_size=200)
+        )
 
         await writer.flush()
 
@@ -474,9 +474,9 @@ async def test_finalize_lifecycle(self, mock_appendable_writer):
         writer.write_obj_stream = mock_appendable_writer["mock_stream"]
 
         resource = storage_type.Object(size=999)
-        mock_appendable_writer[
-            "mock_stream"
-        ].recv.return_value = storage_type.BidiWriteObjectResponse(resource=resource)
+        mock_appendable_writer["mock_stream"].recv.return_value = (
+            storage_type.BidiWriteObjectResponse(resource=resource)
+        )
 
         res = await writer.finalize()
 
@@ -534,9 +534,9 @@ async def test_finalize_with_checksum(self, mock_appendable_writer):
         writer.write_obj_stream = mock_appendable_writer["mock_stream"]
 
         resource = storage_type.Object(size=999)
-        mock_appendable_writer[
-            "mock_stream"
-        ].recv.return_value = storage_type.BidiWriteObjectResponse(resource=resource)
+        mock_appendable_writer["mock_stream"].recv.return_value = (
+            storage_type.BidiWriteObjectResponse(resource=resource)
+        )
 
         checksum = 12345678
         res = await writer.finalize(full_object_checksum=checksum)
@@ -655,7 +655,9 @@ async def test_finalize_custom_retry_policy(self, mock_appendable_writer):
         writer._is_stream_open = True
         writer.write_obj_stream = mock_appendable_writer["mock_stream"]
 
-        custom_policy = AsyncRetry(predicate=lambda exc: isinstance(exc, exceptions.InternalServerError))
+        custom_policy = AsyncRetry(
+            predicate=lambda exc: isinstance(exc, exceptions.InternalServerError)
+        )
         resource = storage_type.Object(size=999)
         mock_appendable_writer["mock_stream"].recv.return_value = (
             storage_type.BidiWriteObjectResponse(resource=resource)
@@ -665,7 +667,9 @@ async def test_finalize_custom_retry_policy(self, mock_appendable_writer):
         assert res == resource
 
     @pytest.mark.asyncio
-    async def test_close_with_finalize_and_custom_retry_policy(self, mock_appendable_writer):
+    async def test_close_with_finalize_and_custom_retry_policy(
+        self, mock_appendable_writer
+    ):
         from google.api_core.retry_async import AsyncRetry
 
         writer = self._make_one(mock_appendable_writer["mock_client"])
@@ -697,6 +701,3 @@ async def test_close_retry_on_transient_error(self, mock_appendable_writer):
         assert writer.persisted_size == 999
         assert mock_appendable_writer["mock_stream"].send.await_count == 2
         assert not writer._is_stream_open
-
-
-