style(storage): fix import ordering and formatting in system and unit tests

Author: chandra-siri

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

@@ -31,6 +31,7 @@
 import pytest  # noqa: E402
 from google.api_core import exceptions  # noqa: E402
 from google.api_core.client_options import ClientOptions  # noqa: E402
+
 from google.cloud import kms  # noqa: E402
 from google.cloud.storage._helpers import _base64_md5hash  # noqa: E402
 from google.cloud.storage.retry import DEFAULT_RETRY  # noqa: E402
@@ -113,10 +114,12 @@ def _kms_key_name(client, bucket, key_name):
         key_name,
     )
 
+
 @pytest.fixture(scope="session")
 def run_system_tests_on_preprod():
     return os.getenv("RUN_SYSTEM_TESTS_ON_PREPROD") == "True"
 
+
 @pytest.fixture(scope="session")
 def storage_client(run_system_tests_on_preprod):
     from google.cloud.storage import Client

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

@@ -61,6 +61,7 @@
 _RCU_BUCKET = os.getenv("RCU_BUCKET")
 _BUCKET_UNDER_TEST = _RCU_BUCKET if RCU_SYSTEM_TESTS else _ZONAL_BUCKET
 
+
 async def create_async_grpc_client(attempt_direct_path=True, preprod=False):
     """Initializes async client and gets the current event loop."""
     return AsyncGrpcClient(
@@ -169,7 +170,10 @@ def _get_equal_dist(a: int, b: int) -> tuple[int, int]:
     step = (b - a) // 3
     return a + step, a + 2 * step
 
-@pytest.mark.skipif(RCU_SYSTEM_TESTS, reason='X regions reads/writes for RCU not supported in SDK yet')
+
+@pytest.mark.skipif(
+    RCU_SYSTEM_TESTS, reason="X regions reads/writes for RCU not supported in SDK yet"
+)
 @pytest.mark.parametrize(
     "object_size",
     [
@@ -388,7 +392,10 @@ async def _run():
 
     event_loop.run_until_complete(_run())
 
-@pytest.mark.skipif(RCU_SYSTEM_TESTS, reason='Write from blob for RCU not supported in SDK yet')
+
+@pytest.mark.skipif(
+    RCU_SYSTEM_TESTS, reason="Write from blob for RCU not supported in SDK yet"
+)
 def test_write_from_blob(
     storage_client,
     blobs_to_delete,
@@ -441,7 +448,10 @@ async def _run():
     event_loop.run_until_complete(_run())
 
 
-@pytest.mark.skipif(RCU_SYSTEM_TESTS, reason='Write from blob with KMS key for RCU not supported in SDK yet')
+@pytest.mark.skipif(
+    RCU_SYSTEM_TESTS,
+    reason="Write from blob with KMS key for RCU not supported in SDK yet",
+)
 def test_write_from_blob_with_kms_key(
     storage_client,
     blobs_to_delete,
@@ -482,7 +492,9 @@ async def _run():
     event_loop.run_until_complete(_run())
 
 
-@pytest.mark.skipif(RCU_SYSTEM_TESTS, reason='Write blob with contexts for RCU not supported in SDK yet')
+@pytest.mark.skipif(
+    RCU_SYSTEM_TESTS, reason="Write blob with contexts for RCU not supported in SDK yet"
+)
 @pytest.mark.asyncio
 async def test_write_blob_with_contexts(storage_client, blobs_to_delete):
     async_client = await create_async_grpc_client()

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

@@ -139,9 +139,7 @@ async def test_open_new_object_with_storage_class(
         initial_request = call_args.kwargs["initial_request"]
         assert initial_request.write_object_spec is not None
         assert initial_request.write_object_spec.resource.name == OBJECT
-        assert (
-            initial_request.write_object_spec.resource.storage_class == storage_class
-        )
+        assert initial_request.write_object_spec.resource.storage_class == storage_class
         assert initial_request.write_object_spec.appendable
 
         assert stream.is_stream_open