Function run_migrations

code_review_graph/migrations.py:259–284

Run all pending migrations in order. Each migration runs in its own transaction. The schema_version metadata entry is updated after each successful migration.

(conn: sqlite3.Connection)

def run_migrations(conn: sqlite3.Connection) -> None:
    """Run all pending migrations in order.

    Each migration runs in its own transaction. The schema_version metadata
    entry is updated after each successful migration.
    """
    current = get_schema_version(conn)
    if current >= LATEST_VERSION:
        return

    logger.info("Schema version %d -> %d: running migrations", current, LATEST_VERSION)

    for version in sorted(MIGRATIONS.keys()):
        if version <= current:
            continue
        logger.info("Running migration v%d", version)
        try:
            MIGRATIONS[version](conn)
            _set_schema_version(conn, version)
            conn.commit()
        except sqlite3.Error:
            conn.rollback()
            logger.error("Migration v%d failed, rolling back", version, exc_info=True)
            raise

    logger.info("Migrations complete, now at schema version %d", LATEST_VERSION)