From: jackwotherspoon Date: Mon, 29 May 2023 16:18:12 +0000 (+0000) Subject: chore: lint X-Git-Url: http://git.ipfire.org/?a=commitdiff_plain;h=f195c10f506c5644259355b044f88e72fca7feaf;p=thirdparty%2Fsqlalchemy%2Fsqlalchemy.git chore: lint --- diff --git a/lib/sqlalchemy/ext/asyncio/engine.py b/lib/sqlalchemy/ext/asyncio/engine.py index b4d0579b2f..7cb2e6e692 100644 --- a/lib/sqlalchemy/ext/asyncio/engine.py +++ b/lib/sqlalchemy/ext/asyncio/engine.py @@ -84,6 +84,7 @@ def create_async_engine(url: Union[str, URL], **kw: Any) -> AsyncEngine: kw["_is_async"] = True async_creator = kw.pop("async_creator", None) if async_creator: + async def wrap_async_creator() -> Any: return await async_creator() @@ -94,6 +95,7 @@ def create_async_engine(url: Union[str, URL], **kw: Any) -> AsyncEngine: return sync_engine.dialect.dbapi.connect( creator_fn=wrap_async_creator ) + kw["creator"] = creator sync_engine = _create_engine(url, **kw) return AsyncEngine(sync_engine) @@ -1088,7 +1090,6 @@ class AsyncEngine(ProxyComparable[Engine], AsyncConnectable): return AsyncEngine(self.sync_engine.execution_options(**opt)) async def dispose(self, close: bool = True) -> None: - """Dispose of the connection pool used by this :class:`_asyncio.AsyncEngine`.