Method get

trinity/buffer/storage/queue.py:162–169

(self)

        await super().put(item)

    async def get(self):
        while True:
            item = await super().get()
            if (
                self.min_model_version <= 0
                or item[0].info["model_version"] >= self.min_model_version
            ):
                return item

    async def close(self) -> None:
        """Close the queue."""