Function count_session_rows

app/api/agentops/exporter/processor.py:514–527

Count the number of rows in the sessions table

()

async def count_session_rows() -> int:
    """Count the number of rows in the sessions table"""
    query = """
        SELECT COUNT(*) FROM sessions
        WHERE id > '{last_session_id}'
    """
    query = query.format(
        last_session_id=LAST_SESSION_ID if LAST_SESSION_ID else '00000000-0000-0000-0000-000000000000'
    )
    async with get_supabase_pool().connection() as conn:
        async with conn.cursor() as cur:
            await cur.execute(query)
            rows = await cur.fetchone()
    return rows[0]


def init_files():