Method fetchone

app/api/agentops/exporter/processor.py:171–176

(self, query: str, **kwargs)

                    yield self.get_model_instance(**row)

    async def fetchone(self, query: str, **kwargs) -> BaseModel:
        query = query.format(table_name=self.table_name, **kwargs)
        async with get_supabase_pool().connection() as conn:
            async with conn.cursor(row_factory=psycopg.rows.dict_row) as cur:
                await cur.execute(query)
                return self.get_model_instance(**await cur.fetchone())


supabase = SupabaseExporter