def get(self):
        if (self._any_due() and self.rate_limit.peek()):
            with self.queue_lock:
                ready_items = list()
                unready_items = deque()
                for i in self.queue:
                    if i.is_ready():
                        ready_items.append(i.item)
                    else:
                        unready_items.append(i)
                self.queue = unready_items
                self.rate_limit.ping()
                return ready_items
        else:
            return list()
Gets the list of ready items if any items are due
dataset/ETHPy150Open StorjOld/downstream-farmer/downstream_farmer/utils.py/BurstQueue.get