/
githubmirror
/
gpt-pilot
Обзор
Документация
Войти
/
githubmirror
/
gpt-pilot
Код
Запросы
0
Пакеты
0
Релизы
0
Аналитика
Безопасность
main
core/db/setup.py
49 строк
1 KB
Senko Rasic
merge gpt-pilot 0.2 codebase
22 май 2024, 22:42
22 май 2024, 22:42
5b474cc
Код
Авторство
О чём код?
from os.path import dirname, join from alembic import command from alembic.config import Config from core.config import DBConfig from core.log import get_logger log = get_logger(__name__) def _async_to_sync_db_scheme(url: str) -> str: """ Convert an async database URL to a synchronous one. This is needed because Alembic does not support async database connections. :param url: Asynchronouse database URL. :return: Synchronous database URL. """ if url.startswith("postgresql+asyncpg://"): return url.replace("postgresql+asyncpg://", "postgresql://") elif url.startswith("sqlite+aiosqlite://"): return url.replace("sqlite+aiosqlite://", "sqlite://") return url def run_migrations(config: DBConfig): """ Run database migrations using Alembic. This needs to happen synchronously, before the asyncio mainloop is started, and before any database access. :param config: Database configuration. """ url = _async_to_sync_db_scheme(config.url) ini_location = join(dirname(__file__), "alembic.ini") log.debug(f"Running database migrations for {url} (config: {ini_location})") alembic_cfg = Config(ini_location) alembic_cfg.set_main_option("sqlalchemy.url", url) alembic_cfg.set_main_option("pythagora_runtime", "true") command.upgrade(alembic_cfg, "head") __all__ = ["run_migrations"]