INNER CODE UNIT · Python

new_async_engine

dialoguemd/fastapi-sqla · fastapi_sqla/async_sqla.py:32

def new_async_engine(
    key: str = _DEFAULT_SESSION_KEY,
) -> AsyncEngine | AsyncConnection:
    envvar_prefix = get_envvar_prefix(key)
    config = _get_engine_config(envvar_prefix)
    return async_engine_from_config(config, prefix=envvar_prefix)


async def startup(key: str = _DEFAULT_SESSION_KEY):
    engine_or_connection = new_async_engine(key)
    aws_rds_iam_support.setup(engine_or_connection.sync_engine)
    aws_aurora_support.setup(engine_or_connection.sync_engine)

    async_engine = (
        engine_or_connection
        if isinstance(engine_or_connection, AsyncEngine)
        else engine_or_connection.engine
    )

View source record →