Fixed missing await statement in alembic setup
This commit is contained in:
@@ -106,9 +106,9 @@ async def run_async_migrations() -> None:
|
|||||||
# PostgreSQL will emit all CREATE / ALTER / DROP statements
|
# PostgreSQL will emit all CREATE / ALTER / DROP statements
|
||||||
# in terms of this schema by default
|
# 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
|
# in SQLAlchemy v2+ the search path change needs to be committed
|
||||||
connection.commit()
|
await connection.commit()
|
||||||
await connection.run_sync(do_run_migrations)
|
await connection.run_sync(do_run_migrations)
|
||||||
|
|
||||||
await connectable.dispose()
|
await connectable.dispose()
|
||||||
|
|||||||
Reference in New Issue
Block a user