Method read

trinity/buffer/storage/sql.py:223–228

(self, batch_size: Optional[int] = None, **kwargs)

        return exp_list

    async def read(self, batch_size: Optional[int] = None, **kwargs) -> List[Experience]:
        await self.prepare()
        if self.stopped:
            raise StopAsyncIteration()
        batch_size = self.batch_size if batch_size is None else batch_size
        return await self._read_method(batch_size, **kwargs)

    def _build_filter_conditions(self, filters: Optional[Dict] = None):
        conditions = []