async def METHOD_NAME(dsn: DataSourceName) -> Engine:
    engine = await create_pg_engine(dsn, minsize=1, maxsize=4)
    try:
        await raise_if_migration_not_ready(engine)
    except Exception:
        await close_engine(engine)
        raise
    return engine