summaryrefslogtreecommitdiff
path: root/lib/sqlalchemy/ext/asyncio/session.py
diff options
context:
space:
mode:
Diffstat (limited to 'lib/sqlalchemy/ext/asyncio/session.py')
-rw-r--r--lib/sqlalchemy/ext/asyncio/session.py7
1 files changed, 5 insertions, 2 deletions
diff --git a/lib/sqlalchemy/ext/asyncio/session.py b/lib/sqlalchemy/ext/asyncio/session.py
index 4ae1fb385..c21b67954 100644
--- a/lib/sqlalchemy/ext/asyncio/session.py
+++ b/lib/sqlalchemy/ext/asyncio/session.py
@@ -1,7 +1,7 @@
-from typing import Any
from typing import Callable
from typing import Mapping
from typing import Optional
+from typing import TypeVar
from . import engine
from . import result as _result
@@ -14,6 +14,9 @@ from ...sql import Executable
from ...util.concurrency import greenlet_spawn
+T = TypeVar("T")
+
+
@util.create_proxy_methods(
Session,
":class:`_orm.Session`",
@@ -102,7 +105,7 @@ class AsyncSession:
with_for_update=with_for_update,
)
- async def run_sync(self, fn: Callable, *arg, **kw) -> Any:
+ async def run_sync(self, fn: Callable[..., T], *arg, **kw) -> T:
"""Invoke the given sync callable passing sync self as the first
argument.