From c531ef415a279eed39b8bac39e5c0bd0d7a399b9 Mon Sep 17 00:00:00 2001 From: pablodanswer Date: Thu, 17 Oct 2024 19:38:34 -0700 Subject: [PATCH] k --- backend/alembic/env.py | 9 +++------ 1 file changed, 3 insertions(+), 6 deletions(-) diff --git a/backend/alembic/env.py b/backend/alembic/env.py index faced82ee..c89d34552 100644 --- a/backend/alembic/env.py +++ b/backend/alembic/env.py @@ -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,