remove unused imports

Author: Pulkit0110

google/cloud/storage/_experimental/asyncio/async_multi_range_downloader.py

@@ -14,16 +14,13 @@
 
 from __future__ import annotations
 import asyncio
-import google_crc32c
 from google.api_core import exceptions
 from google.api_core.retry_async import AsyncRetry
 from google.cloud._storage_v2.types import BidiReadObjectRedirectedError
 from google.rpc import status_pb2
 
 from typing import List, Optional, Tuple, Any, Dict
 
-from google_crc32c import Checksum
-
 from ._utils import raise_if_no_fast_crc32c
 from google.cloud.storage._experimental.asyncio.async_read_object_stream import (
     _AsyncReadObjectStream,
@@ -278,8 +275,6 @@ def combined_on_error(exc):
             ).with_on_error(combined_on_error)
 
         async def _do_open():
-            nonlocal metadata
-
             current_metadata = list(metadata) if metadata else []
 
             # Cleanup stream from previous failed attempt, if any.

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

@@ -14,7 +14,6 @@
 
 from typing import Any, Dict, List, IO
 
-import grpc
 from google.api_core import exceptions
 from google.rpc import status_pb2
 from google_crc32c import Checksum

tests/conformance/bidi_reads_test.py

@@ -11,8 +11,6 @@
 from google.auth import credentials as auth_credentials
 from google.cloud import _storage_v2 as storage_v2
 
-# Import the components you are building
-from google.cloud.storage._experimental.asyncio.async_grpc_client import AsyncGrpcClient
 from google.cloud.storage._experimental.asyncio.async_multi_range_downloader import AsyncMultiRangeDownloader
 
 # --- Configuration ---
@@ -51,7 +49,6 @@ async def run_test_scenario(gapic_client, http_client, bucket_name, object_name,
         fault_injection_metadata = (("x-retry-test-id", retry_test_id),)
 
         buffer = io.BytesIO()
-        fast_retry = AsyncRetry(predicate=_is_retriable, deadline=15, initial=0.1)
 
         # 3. Execute the download and assert the outcome.
         try:
@@ -158,7 +155,7 @@ async def write_req_gen():
         for scenario in open_test_scenarios:
             await run_open_test_scenario(gapic_client, http_client, bucket_name, object_name, scenario)
 
-    except Exception as e:
+    except Exception:
         import traceback
         traceback.print_exc()
     finally: