fix lint issues

Author: sagnghos

google/cloud/spanner_dbapi/connection.py

@@ -808,7 +808,7 @@ def connect(
             if isinstance(credentials, AnonymousCredentials):
                 client_options = kwargs.get("client_options")
             if experimental_host is not None:
-                project="default"
+                project = "default"
                 credentials = AnonymousCredentials()
                 client_options = ClientOptions(api_endpoint=experimental_host)
             client = spanner.Client(

google/cloud/spanner_v1/database.py

@@ -205,7 +205,9 @@ def __init__(
         pool.bind(self)
         is_experimental_host = self._instance.experimental_host is not None
 
-        self._sessions_manager = DatabaseSessionsManager(self, pool, is_experimental_host)
+        self._sessions_manager = DatabaseSessionsManager(
+            self, pool, is_experimental_host
+        )
 
     @classmethod
     def from_pb(cls, database_pb, instance, pool=None):
@@ -455,7 +457,9 @@ def spanner_api(self):
                     channel=grpc.insecure_channel(self._instance.experimental_host)
                 )
                 self._spanner_api = SpannerClient(
-                    client_info=client_info, transport=transport, client_options=client_options
+                    client_info=client_info,
+                    transport=transport,
+                    client_options=client_options,
                 )
                 return self._spanner_api
             credentials = self._instance._client.credentials

google/cloud/spanner_v1/testing/database_test.py

@@ -93,7 +93,9 @@ def spanner_api(self):
                 channel = grpc.intercept_channel(channel, *self._interceptors)
                 transport = SpannerGrpcTransport(channel=channel)
                 self._spanner_api = SpannerClient(
-                    client_info=client_info, transport=transport, client_options=client_options
+                    client_info=client_info,
+                    transport=transport,
+                    client_options=client_options,
                 )
                 return self._spanner_api
             credentials = client.credentials

tests/system/conftest.py

@@ -48,11 +48,13 @@ def not_emulator():
     if _helpers.USE_EMULATOR:
         pytest.skip(f"{_helpers.USE_EMULATOR_ENVVAR} set in environment.")
 
+
 @pytest.fixture(scope="module")
 def not_experimental_host():
     if _helpers.USE_EXPERIMENTAL_HOST:
         pytest.skip(f"{_helpers.USE_EXPERIMENTAL_HOST_ENVVAR} set in environment.")
 
+
 @pytest.fixture(scope="session")
 def not_postgres(database_dialect):
     if database_dialect == DatabaseDialect.POSTGRESQL:
@@ -115,7 +117,7 @@ def spanner_client():
         return spanner_v1.Client(
             project=_helpers.EXPERIMENTAL_HOST_PROJECT,
             credentials=credentials,
-            experimental_host=_helpers.EXPERIMENTAL_HOST
+            experimental_host=_helpers.EXPERIMENTAL_HOST,
         )
     else:
         client_options = {"api_endpoint": _helpers.API_ENDPOINT}

tests/system/test_backup_api.py

@@ -26,13 +26,16 @@
 Remove {_helpers.SKIP_BACKUP_TESTS_ENVVAR} from environment to run these tests.\
 """
 skip_emulator_reason = "Backup operations not supported by emulator."
-skip_experimental_host_reason = "Backup operations not supported on experimental host yet."
+skip_experimental_host_reason = (
+    "Backup operations not supported on experimental host yet."
+)
 
 pytestmark = [
     pytest.mark.skipif(_helpers.SKIP_BACKUP_TESTS, reason=skip_env_reason),
     pytest.mark.skipif(_helpers.USE_EMULATOR, reason=skip_emulator_reason),
-    pytest.mark.skipif(_helpers.USE_EXPERIMENTAL_HOST, reason=skip_experimental_host_reason),
-
+    pytest.mark.skipif(
+        _helpers.USE_EXPERIMENTAL_HOST, reason=skip_experimental_host_reason
+    ),
 ]
 
 

tests/system/test_database_api.py

@@ -47,7 +47,9 @@
 
 
 @pytest.fixture(scope="module")
-def multiregion_instance(spanner_client, instance_operation_timeout, not_postgres, not_experimental_host):
+def multiregion_instance(
+    spanner_client, instance_operation_timeout, not_postgres, not_experimental_host
+):
     multi_region_instance_id = _helpers.unique_id("multi-region")
     multi_region_config = "nam3"
     config_name = "{}/instanceConfigs/{}".format(
@@ -764,7 +766,11 @@ def test_information_schema_referential_constraints_fkadc(
 
 
 def test_update_database_success(
-    not_emulator, not_experimental_host, shared_database, shared_instance, database_operation_timeout
+    not_emulator,
+    not_experimental_host,
+    shared_database,
+    shared_instance,
+    database_operation_timeout,
 ):
     old_protection = shared_database.enable_drop_protection
     new_protection = True

tests/system/test_dbapi.py

@@ -1436,7 +1436,13 @@ def test_ping(self):
     @pytest.mark.noautofixt
     def test_user_agent(self, shared_instance, dbapi_database):
         """Check that DB API uses an appropriate user agent."""
-        conn = connect(shared_instance.name, dbapi_database.name, experimental_host=_helpers.EXPERIMENTAL_HOST if _helpers.USE_EXPERIMENTAL_HOST else None)
+        conn = connect(
+            shared_instance.name,
+            dbapi_database.name,
+            experimental_host=_helpers.EXPERIMENTAL_HOST
+            if _helpers.USE_EXPERIMENTAL_HOST
+            else None,
+        )
         assert (
             conn.instance._client._client_info.user_agent
             == "gl-dbapi/" + package_version.__version__