merge_db_fixes_to_main #16
@@ -93,7 +93,9 @@ async def create_all_tables() -> None:
|
||||
async with engine.begin() as conn:
|
||||
# Set search path if schema is configured
|
||||
if schema:
|
||||
await conn.execute(text(f"CREATE SCHEMA IF NOT EXISTS {schema}"))
|
||||
# Only create schema if it's not 'public' (public always exists)
|
||||
if schema != "public":
|
||||
await conn.execute(text(f"CREATE SCHEMA IF NOT EXISTS {schema}"))
|
||||
await conn.execute(text(f"SET search_path TO {schema}"))
|
||||
|
||||
# Create all tables
|
||||
|
||||
Reference in New Issue
Block a user