Function init_db

src/orgkernel/database.py:76–96

Create all OrgKernel tables in the database. Call this once at application startup (after setting the engine URL). Args: engine: AsyncEngine to use. Defaults to the global async_engine. Note: On PostgreSQL, run ``CREATE EXTENSION IF NOT EXISTS pgcrypto;``

(engine: AsyncEngine | None = None)

async def init_db(engine: AsyncEngine | None = None) -> None:
    """
    Create all OrgKernel tables in the database.

    Call this once at application startup (after setting the engine URL).

    Args:
        engine: AsyncEngine to use. Defaults to the global async_engine.

    Note:
        On PostgreSQL, run ``CREATE EXTENSION IF NOT EXISTS pgcrypto;`` first
        to enable SHA-256 hashing functions.
    """
    global async_engine
    target_engine = engine or async_engine
    if target_engine is None:
        raise RuntimeError(
            "No engine set. Pass an engine argument or set orgkernel.database.async_engine.url first."
        )
    async with target_engine.begin() as conn:
        await conn.run_sync(BaseModel.metadata.create_all)


async def close_db() -> None: