async def METHOD_NAME(self, query: str, values: list) -> Optional[asyncpg.Record]:
    async with self.acquire_connection() as connection:
        self.log.debug("%s: %s", query, values)
        # TODO: Cache prepared statement
        return await connection.fetchrow(query, *values)