Function run_async

tortoise/__init__.py:555–585

Simple async runner that cleans up DB connections on exit. This is meant for simple scripts. Usage:: from tortoise import Tortoise, run_async async def do_stuff(): await Tortoise.init( db_url='sqlite://db.sqlite3', models={'

(coro: Coroutine)

def run_async(coro: Coroutine) -> None:
    """
    Simple async runner that cleans up DB connections on exit.
    This is meant for simple scripts.

    Usage::

        from tortoise import Tortoise, run_async

        async def do_stuff():
            await Tortoise.init(
                db_url='sqlite://db.sqlite3',
                models={'models': ['app.models']}
            )

            ...

        run_async(do_stuff())
    """
    from tortoise.context import get_current_context

    async def main() -> None:
        try:
            await coro
        finally:
            ctx = get_current_context()
            if ctx is not None:
                await ctx.connections.close_all(discard=True)

    with from_thread.start_blocking_portal() as portal:
        portal.call(main)


__version__ = "1.1.7"