Method _should_stop

trinity/buffer/task_scheduler.py:181–182

(self)

        return taskset_ids

    def _should_stop(self) -> bool:
        return self.step >= self.max_steps

    async def read(self) -> List:
        """Read a batch of tasks according to the current schedule.