style: format with ruff

tembo-pgmq-python/tembo_pgmq_python/sqlalchemy/__init__.py

@@ -1,3 +1,3 @@
-from tembo_pgmq_python.sqlalchemy.queue import PGMQueue 
+from tembo_pgmq_python.sqlalchemy.queue import PGMQueue
 
-__all__ = ["PGMQueue"]
+__all__ = ["PGMQueue"]

tembo-pgmq-python/tembo_pgmq_python/sqlalchemy/_db_api_interface.py

@@ -18,62 +18,49 @@
 
 
 class DBAPIConnection(Protocol):
-    def close(self) -> object:
-        ...
+    def close(self) -> object: ...
 
-    def commit(self) -> object:
-        ...
+    def commit(self) -> object: ...
 
     # optional:
     # def rollback(self) -> Any: ...
-    def cursor(self) -> "DBAPICursor":
-        ...
+    def cursor(self) -> "DBAPICursor": ...
 
 
 class DBAPICursor(Protocol):
     @property
-    def description(self) -> Union[Sequence[DBAPIColumnDescription], None]:
-        ...
+    def description(self) -> Union[Sequence[DBAPIColumnDescription], None]: ...
 
     @property
-    def rowcount(self) -> int:
-        ...
+    def rowcount(self) -> int: ...
 
     # optional:
     # def callproc(self, procname: str, parameters: Sequence[Any] = ..., /) -> Sequence[Any]: ...
-    def close(self) -> object:
-        ...
+    def close(self) -> object: ...
 
     def execute(
         self,
         operation: str,
         parameters: Union[Sequence[Any], Mapping[str, Any]] = ...,
         /,
-    ) -> object:
-        ...
+    ) -> object: ...
 
     def executemany(
         self, operation: str, seq_of_parameters: Sequence[Sequence[Any]], /
-    ) -> object:
-        ...
+    ) -> object: ...
 
-    def fetchone(self) -> Union[Sequence[Any], None]:
-        ...
+    def fetchone(self) -> Union[Sequence[Any], None]: ...
 
-    def fetchmany(self, size: int = ..., /) -> Sequence[Sequence[Any]]:
-        ...
+    def fetchmany(self, size: int = ..., /) -> Sequence[Sequence[Any]]: ...
 
-    def fetchall(self) -> Sequence[Sequence[Any]]:
-        ...
+    def fetchall(self) -> Sequence[Sequence[Any]]: ...
 
     # optional:
     # def nextset(self) -> None | Literal[True]: ...
     arraysize: int
 
     def setinputsizes(
         self, sizes: Sequence[Union[DBAPITypeCode, int, None]], /
-    ) -> object:
-        ...
+    ) -> object: ...
 
-    def setoutputsize(self, size: int, column: int = ..., /) -> object:
-        ...
+    def setoutputsize(self, size: int, column: int = ..., /) -> object: ...

tembo-pgmq-python/tembo_pgmq_python/sqlalchemy/_types.py

@@ -11,21 +11,21 @@
 SESSION_TYPE = Union[Session, AsyncSession]
 PARAM_STYLE_TYPE = Literal["qmark", "numeric", "named", "format", "pyformat"]
 DIALECTS_TYPE = Literal[
-    'sqlalchemy',
-    'asyncpg',
-    'psycopg2',
-    'psycopg3',
+    "sqlalchemy",
+    "asyncpg",
+    "psycopg2",
+    "psycopg3",
 ]
 STATEMENT_TYPE = Union[Tuple[TextClause, Dict[str, Any]], TextClause]
 
+
 class AsyncDBAPICursor(DBAPICursor):
     async def execute(
         self,
         operation: str,
         parameters: Union[Sequence[Any], Mapping[str, Any]] = ...,
         /,
-    ) -> object:
-        ...
+    ) -> object: ...
 
 
 __all__ = [