Function create_migration_table

backend/tkhelper/database/postgres/migrate.py:10–27

Create migration table if not exists :param conn: asyncpg database connection

(
    conn,
)

async def create_migration_table(
    conn,
):
    """
    Create migration table if not exists

    :param conn: asyncpg database connection
    """
    try:
        await conn.execute(
            f"""
            CREATE TABLE IF NOT EXISTS {MIGRATION_TABLE} (
                version INTEGER PRIMARY KEY
            );
        """
        )
    except Exception as e:
        logger.error(f"Error creating migration table: {e}")


async def get_current_version(