Version 0.05

anysqlite/__init__.py

@@ -40,4 +40,4 @@
     "sqlite_version_info",
     "threadsafety",
 ]
-__version__ = "0.0.4"
+__version__ = "0.0.5"

anysqlite/_core.py

@@ -13,7 +13,7 @@ def __init__(self, _real_connection: sqlite3.Connection) -> None:
 
     async def __aenter__(self) -> "Connection":
         return self
-    
+
     async def __aexit__(self, *args: tp.Any, **kwargs: tp.Any) -> None:
         return await self.close()
 
@@ -48,7 +48,10 @@ async def executemany(
         self, sql: str, seq_of_parameters: tp.Iterable[tp.Iterable[tp.Any]]
     ) -> "Cursor":
         real_cursor = await to_thread.run_sync(
-            self._real_connection.executemany, sql, seq_of_parameters, limiter=self._limiter
+            self._real_connection.executemany,
+            sql,
+            seq_of_parameters,
+            limiter=self._limiter,
         )
         return Cursor(real_cursor, self._limiter)
 
@@ -58,6 +61,7 @@ async def executescript(self, sql_script: str) -> "Cursor":
         )
         return Cursor(real_cursor, self._limiter)
 
+
 class Cursor:
     def __init__(self, real_cursor: sqlite3.Cursor, limiter: CapacityLimiter) -> None:
         self._real_cursor = real_cursor

typetest.py

@@ -0,0 +1,26 @@
+import typing as tp
+import sqlite3
+
+P = tp.ParamSpec("P")
+T = tp.TypeVar("T")
+RT = tp.TypeVar("RT")
+
+def copy_sig(_: tp.Callable[P, T], returns: tp.Callable[..., RT]) -> tp.Callable[[tp.Callable[..., tp.Any]], tp.Callable[P, RT]]:
+
+    def decorator(fnc: tp.Callable[..., tp.Any]) -> tp.Callable[P, RT]:
+
+        def inner(*args, **kwargs):
+            return fnc(*args, **kwargs)
+
+        return inner
+
+    return decorator
+
+@copy_sig(sqlite3.connect, int.__new__)
+async def connect(*args, **kwargs):
+    ...
+
+
+tp.reveal_type(connect)
+a = connect()
+tp.reveal_type(a)