def get(self, queue_name, task_id):
        # This method is *very* non-thread-safe.
        cls = self.__class__
        queue = cls.queues.get(queue_name, [])

        if queue:
            try:
                offset = queue.index(task_id)
            except ValueError:
                return None

            queue.pop(offset)
            return cls.task_data.pop(task_id, None)
Pops a specific task off the queue by identifier.
dataset/ETHPy150Open toastdriven/alligator/alligator/backends/locmem_backend.py/Client.get