chore: fix lint and formatting issues

Author: sinhasubham

google/cloud/spanner_v1/metrics/metrics_capture.py

@@ -63,6 +63,7 @@ def __enter__(self):
 
         if tracer and self._resource_info:
             import logging
+
             logger = logging.getLogger("google.cloud.spanner_v1.metrics")
             logger.info(f"DEBUG: MetricsCapture setting labels: {self._resource_info}")
             if "project" in self._resource_info:

google/cloud/spanner_v1/snapshot.py

@@ -16,6 +16,7 @@
 # This file is automatically generated by CrossSync. Do not edit manually.
 
 """Model a set of read-only queries to a database as a snapshot."""
+
 import functools
 from typing import List, Optional, Union
 from google.api_core import gapic_v1
@@ -49,13 +50,13 @@
     _augment_error_with_request_id,
     _check_rst_stream_error,
     _make_value_pb,
+    _merge_client_context,
     _merge_query_options,
+    _merge_request_options,
     _metadata_with_leader_aware_routing,
     _metadata_with_prefix,
     _SessionWrapper,
     _validate_client_context,
-    _merge_client_context,
-    _merge_request_options,
 )
 from google.cloud.spanner_v1._opentelemetry_tracing import add_span_event, trace_call
 from google.cloud.spanner_v1.metrics.metrics_capture import MetricsCapture
@@ -118,10 +119,11 @@ def _restart_on_unavailable(
                     observability_options=observability_options,
                     metadata=metadata,
                 ) as span, MetricsCapture(resource_info):
-                    (call_metadata, current_request_id) = (
-                        request_id_manager.metadata_and_request_id(
-                            nth_request, attempt, metadata, span
-                        )
+                    (
+                        call_metadata,
+                        current_request_id,
+                    ) = request_id_manager.metadata_and_request_id(
+                        nth_request, attempt, metadata, span
                     )
                     iterator = CrossSync._Sync_Impl.run_if_async(
                         method, request=request, metadata=call_metadata
@@ -320,7 +322,7 @@ def execute_sql(
                 raise ValueError("Transaction has not begun.")
         if params is not None:
             params_pb = Struct(
-                fields={key: _make_value_pb(value) for (key, value) in params.items()}
+                fields={key: _make_value_pb(value) for key, value in params.items()}
             )
         else:
             params_pb = {}
@@ -511,7 +513,7 @@ def partition_query(
             raise ValueError("Cannot partition a single-use transaction.")
         if params is not None:
             params_pb = Struct(
-                fields={key: _make_value_pb(value) for (key, value) in params.items()}
+                fields={key: _make_value_pb(value) for key, value in params.items()}
             )
         else:
             params_pb = Struct()
@@ -612,7 +614,7 @@ def wrapped_method():
                 begin_transaction_request = BeginTransactionRequest(
                     **begin_request_kwargs
                 )
-                (call_metadata, error_augmenter) = database.with_error_augmentation(
+                call_metadata, error_augmenter = database.with_error_augmentation(
                     nth_request, attempt.increment(), metadata, span
                 )
                 begin_transaction_method = functools.partial(

google/cloud/spanner_v1/testing/database_test.py

@@ -119,9 +119,10 @@ def spanner_api(self):
         return self._spanner_api
 
     def _create_spanner_client_for_tests(self, client_options, credentials):
-        (api_endpoint, client_cert_source_func) = (
-            SpannerClient.get_mtls_endpoint_and_cert_source(client_options)
-        )
+        (
+            api_endpoint,
+            client_cert_source_func,
+        ) = SpannerClient.get_mtls_endpoint_and_cert_source(client_options)
         channel = grpc_helpers.create_channel(
             api_endpoint,
             credentials=credentials,

tests/system/_helpers.py

@@ -23,9 +23,7 @@
 from tests import _fixtures
 
 CREATE_INSTANCE_ENVVAR = "GOOGLE_CLOUD_TESTS_CREATE_SPANNER_INSTANCE"
-CREATE_INSTANCE = (
-    os.getenv(CREATE_INSTANCE_ENVVAR, "false").lower() == "true"
-)
+CREATE_INSTANCE = os.getenv(CREATE_INSTANCE_ENVVAR, "false").lower() == "true"
 
 INSTANCE_ID_ENVVAR = "GOOGLE_CLOUD_TESTS_SPANNER_INSTANCE"
 INSTANCE_ID_DEFAULT = "google-cloud-python-systest"