chore: migrate to ruff formater (#540)

Fixes #443.

Author: enocom

.flake8

@@ -11,11 +11,11 @@
 # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 # See the License for the specific language governing permissions and
 # limitations under the License.
-from google.cloud.alloydbconnector import __version__
 from google.cloud.alloydbconnector import AsyncConnector
 from google.cloud.alloydbconnector import Connector
 from google.cloud.alloydbconnector import IPTypes
 from google.cloud.alloydbconnector import RefreshStrategy
+from google.cloud.alloydbconnector import __version__
 
 __all__ = [
     "__version__",

google/cloud/alloydb/connector/__init__.py

@@ -17,12 +17,13 @@
 import asyncio
 import logging
 from types import TracebackType
-from typing import Any, Optional, TYPE_CHECKING
+from typing import TYPE_CHECKING
+from typing import Any
+from typing import Optional
 
 import google.auth
 from google.auth.credentials import with_scopes_if_required
 import google.auth.transport.requests
-
 import google.cloud.alloydbconnector.asyncpg as asyncpg
 from google.cloud.alloydbconnector.client import AlloyDBClient
 from google.cloud.alloydbconnector.enums import IPTypes
@@ -178,8 +179,7 @@ async def connect(
                 cache = LazyRefreshCache(instance_uri, self._client, self._keys)
             else:
                 logger.debug(
-                    f"['{instance_uri}']: Refresh strategy is set to background"
-                    " refresh"
+                    f"['{instance_uri}']: Refresh strategy is set to background refresh"
                 )
                 cache = RefreshAheadCache(instance_uri, self._client, self._keys)
             self._cache[instance_uri] = cache

google/cloud/alloydbconnector/async_connector.py

@@ -13,7 +13,8 @@
 # limitations under the License.
 
 import ssl
-from typing import Any, TYPE_CHECKING
+from typing import TYPE_CHECKING
+from typing import Any
 
 SERVER_PROXY_PORT = 5433
 

google/cloud/alloydbconnector/asyncpg.py

@@ -16,18 +16,19 @@
 
 import asyncio
 import logging
-from typing import Optional, TYPE_CHECKING
+from typing import TYPE_CHECKING
+from typing import Optional
 
 from cryptography import x509
+
 from google.api_core.client_options import ClientOptions
 from google.api_core.gapic_v1.client_info import ClientInfo
 from google.auth.credentials import TokenState
 from google.auth.transport import requests
 import google.cloud.alloydb_v1beta as v1beta
-from google.protobuf import duration_pb2
-
 from google.cloud.alloydbconnector.connection_info import ConnectionInfo
 from google.cloud.alloydbconnector.version import __version__ as version
+from google.protobuf import duration_pb2
 
 if TYPE_CHECKING:
     from google.auth.credentials import Credentials

google/cloud/alloydbconnector/client.py

@@ -17,7 +17,8 @@
 from dataclasses import dataclass
 import logging
 import ssl
-from typing import Optional, TYPE_CHECKING
+from typing import TYPE_CHECKING
+from typing import Optional
 
 from aiofiles.tempfile import TemporaryDirectory
 

google/cloud/alloydbconnector/connection_info.py

@@ -24,13 +24,15 @@
 import struct
 from threading import Thread
 from types import TracebackType
-from typing import Any, Callable, Optional, TYPE_CHECKING
+from typing import TYPE_CHECKING
+from typing import Any
+from typing import Callable
+from typing import Optional
 
 from google.auth import default
 from google.auth.credentials import TokenState
 from google.auth.credentials import with_scopes_if_required
 from google.auth.transport import requests
-
 import google.cloud.alloydb_connectors_v1.proto.resources_pb2 as connectorspb
 from google.cloud.alloydbconnector.client import AlloyDBClient
 from google.cloud.alloydbconnector.enums import IPTypes
@@ -221,8 +223,7 @@ async def connect_async(self, instance_uri: str, driver: str, **kwargs: Any) ->
                 cache = LazyRefreshCache(instance_uri, self._client, self._keys)
             else:
                 logger.debug(
-                    f"['{instance_uri}']: Refresh strategy is set to background"
-                    " refresh"
+                    f"['{instance_uri}']: Refresh strategy is set to background refresh"
                 )
                 cache = RefreshAheadCache(instance_uri, self._client, self._keys)
             self._cache[instance_uri] = cache

google/cloud/alloydbconnector/connector.py

@@ -121,8 +121,7 @@ async def _perform_refresh(self) -> ConnectionInfo:
                 self._keys,
             )
             logger.debug(
-                f"['{self._instance_uri}']: Connection info refresh operation"
-                " complete"
+                f"['{self._instance_uri}']: Connection info refresh operation complete"
             )
             logger.debug(
                 f"['{self._instance_uri}']: Current certificate expiration = "

google/cloud/alloydbconnector/instance.py

@@ -91,8 +91,7 @@ async def connect_info(self) -> ConnectionInfo:
                 )
                 return self._cached
             logger.debug(
-                f"['{self._instance_uri}']: Connection info "
-                "refresh operation started"
+                f"['{self._instance_uri}']: Connection info refresh operation started"
             )
             try:
                 conn_info = await self._client.get_connection_info(

google/cloud/alloydbconnector/lazy.py

@@ -11,7 +11,8 @@
 # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 # See the License for the specific language governing permissions and
 # limitations under the License.
-from typing import Any, TYPE_CHECKING
+from typing import TYPE_CHECKING
+from typing import Any
 
 if TYPE_CHECKING:
     import ssl