kw["_is_async"] = True
async_creator = kw.pop("async_creator", None)
if async_creator:
+
async def wrap_async_creator() -> Any:
return await async_creator()
return sync_engine.dialect.dbapi.connect(
creator_fn=wrap_async_creator
)
+
kw["creator"] = creator
sync_engine = _create_engine(url, **kw)
return AsyncEngine(sync_engine)
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`.