scriptoriumadmin/open-webui
1
0
Fork 0
mirror of https://github.com/open-webui/open-webui.git synced 2026-10-09 03:18:18 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 3

refac

Browse source
This commit is contained in:
Timothy Jaeryang Baek 2026-10-07 15:01:08 +04:00
parent 56b6b660a8
commit 65f44053d2
1 changed files with 29 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

32
backend/open_webui/migrations/env.py
View file

@ -1,17 +1,20 @@
from __future__ import annotations
import logging
# Alembic environment configuration runner.
# Coordinates database migrations in both offline and online execution modes.
import logging.config
import logging
import alembic.context
from open_webui.env import DATABASE_PASSWORD, DATABASE_URL, LOG_FORMAT
from alembic.runtime.migration import MigrationContext
from open_webui.env import DATABASE_PASSWORD, DATABASE_SCHEMA, DATABASE_URL, LOG_FORMAT
from open_webui.internal.db import enable_iam_token_auth, extract_ssl_params_from_url, reattach_ssl_params_to_url
from open_webui.models.auths import Auth
from open_webui.models.calendar import Calendar, CalendarEvent, CalendarEventAttendee # noqa: F401
from open_webui.models.chat_messages import ChatMessage # noqa: F401
from open_webui.models.chats import Chat # noqa: F401
from sqlalchemy import create_engine, engine_from_config, pool
from sqlalchemy import create_engine, engine_from_config, inspect, pool
alembic_config = alembic.context.config
if alembic_config.config_file_name:
@ -72,6 +75,29 @@ def run_migrations_online() -> None:
live_connectable = _get_engine_connectable()
enable_iam_token_auth(live_connectable)
with live_connectable.connect() as live_connection:
if DATABASE_SCHEMA and live_connection.dialect.name == 'postgresql':
inspector = inspect(live_connection)
if not inspector.has_schema(DATABASE_SCHEMA):
raise RuntimeError(f'DATABASE_SCHEMA={DATABASE_SCHEMA!r} does not exist.')
tables = inspector.get_table_names(schema=DATABASE_SCHEMA)
revisions = MigrationContext.configure(
live_connection, opts={'version_table_schema': DATABASE_SCHEMA}
).get_current_heads()
# Do not replay migrations or hide an existing installation's history.
if not revisions and (
tables or set(inspector.get_table_names()) & {'alembic_version', 'auth', 'chat', 'config'}
):
raise RuntimeError(
f'Cannot migrate DATABASE_SCHEMA={DATABASE_SCHEMA!r}: existing tables or migration '
'history were found, but this schema has no recorded revision. '
'Check DATABASE_SCHEMA and keep the application tables and alembic_version together '
'before restarting.'
)
schema = live_connection.dialect.identifier_preparer.quote_identifier(DATABASE_SCHEMA)
live_connection.exec_driver_sql(f'SET search_path TO {schema}')
live_connection.commit()
alembic.context.configure(
connection=live_connection,
target_metadata=migration_metadata,