Revert "style: apply black formatting to test_async_appendable_object_writer.py"

This reverts commit 5bce9db.

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,9 +655,7 @@ 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)
@@ -667,9 +665,7 @@ 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"])
@@ -701,3 +697,6 @@ 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
+
+
+