Method fetchall

app/api/agentops/exporter/processor.py:162–169

(self, query: str, **kwargs)

            write_dropped_record(self.table_name, kwargs.get('id', 'unknown'), e)

    async def fetchall(self, query: str, **kwargs) -> AsyncGenerator[BaseModel, None]:
        query = query.format(table_name=self.table_name, **kwargs)
        async with get_supabase_pool().connection() as conn:
            # Use a dictionary row factory to get rows as dictionaries
            async with conn.cursor(row_factory=psycopg.rows.dict_row) as cur:
                await cur.execute(query)
                for row in await cur.fetchall():
                    yield self.get_model_instance(**row)

    async def fetchone(self, query: str, **kwargs) -> BaseModel:
        query = query.format(table_name=self.table_name, **kwargs)