Fixed missing await statement in alembic setup

This commit is contained in:
Jonas Linter
2025-11-18 14:38:21 +01:00
parent ab09fb02eb
commit 34bff6a12a

View File

@@ -106,9 +106,9 @@ async def run_async_migrations() -> None:
# PostgreSQL will emit all CREATE / ALTER / DROP statements
# in terms of this schema by default
connection.execute(text(f"SET search_path TO {SCHEMA}"))
await connection.execute(text(f"SET search_path TO {SCHEMA}"))
# in SQLAlchemy v2+ the search path change needs to be committed
connection.commit()
await connection.commit()
await connection.run_sync(do_run_migrations)
await connectable.dispose()