highperfocused/danswer
1
0
Fork 0
mirror of https://github.com/danswer-ai/danswer.git synced 2025-03-26 17:51:54 +01:00
Code Issues Packages Projects Releases Wiki Activity

k

Browse Source
This commit is contained in:
pablodanswer 2024-10-17 19:38:34 -07:00
parent 98d41aac2e
commit c531ef415a
1 changed files with 3 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
backend/alembic/env.py
View File

@ -129,18 +129,16 @@ async def run_async_migrations() -> None:
logger.error(f"Error migrating schema {schema}: {e}")
raise
else:
# Run migrations for a single schema (public if MULTI_TENANT is True)
schema_to_use = "public" if MULTI_TENANT else schema_name
try:
logger.info(f"Migrating schema: {schema_to_use}")
logger.info(f"Migrating schema: {schema_name}")
async with engine.connect() as connection:
await connection.run_sync(
do_run_migrations,
schema_name=schema_to_use,
schema_name=schema_name,
create_schema=create_schema,
)
except Exception as e:
logger.error(f"Error migrating schema {schema_to_use}: {e}")
logger.error(f"Error migrating schema {schema_name}: {e}")
raise
await engine.dispose()
@ -175,7 +173,6 @@ def run_migrations_offline() -> None:
with context.begin_transaction():
context.run_migrations()
else:
# Run migrations for a single schema (public if MULTI_TENANT is True)
logger.info(f"Migrating schema: {schema_name}")
context.configure(
url=url,