Method put

dwave/cloud/concurrency.py:86–93

(self, item, *args, **kwargs)

    """

    def put(self, item, *args, **kwargs):
        # unpack item, extract priority
        if isinstance(item, concurrent.futures.thread._WorkItem):
            item = _PrioritizedWorkItem(item)
        else:
            item = _PriorityOrderedItem(item)

        super().put(item, *args, **kwargs)

    def get(self, *args, **kwargs):
        prioritized_item = super().get(*args, **kwargs)