stream-fusion-better/stream_fusion/services/postgresql/db_init.py
2026-03-02 11:32:28 +01:00

12 lines
366 B
Python

from sqlalchemy.ext.asyncio import create_async_engine
from .base import Base
from .models.apikey_model import APIKeyModel
from stream_fusion.settings import settings
async def init_db():
engine = create_async_engine(str(settings.pg_url))
async with engine.begin() as conn:
await conn.run_sync(Base.metadata.create_all)
await engine.dispose()