Method get

gpustack/scheduler/queue.py:21–25

(self)

                logger.debug(f"Item {item.__hash__()} already in queue.")

    async def get(self):
        item = await self.queue.get()
        async with self.lock:
            self.set.remove(item)
        return item

    def qsize(self):
        return self.queue.qsize()