Function fetch_all_for_session

app/api/agentops/exporter/processor.py:182–190

Fetch all records for a session from a given table

(model_class: BaseModel, session_id)

async def fetch_all_for_session(model_class: BaseModel, session_id) -> AsyncGenerator[BaseModel, None]:
    """Fetch all records for a session from a given table"""
    query = """
        SELECT * FROM {table_name}
        WHERE session_id = '{session_id}'
    """
    exporter = supabase[model_class]
    async for result in exporter.fetchall(query, session_id=session_id):
        yield result


async def get_session_as_trace(session: Session) -> Trace: