Method get

lada/utils/threading_utils.py:60–64

(self, block=True, timeout=None)

        self.stats[f"{self.name}_wait_time_put"] += time.time() - s

    def get(self, block=True, timeout=None):
        s = time.time()
        item = super().get(block=block, timeout=timeout)
        self.stats[f"{self.name}_wait_time_get"] += time.time() - s
        return item

def put_queue_stop_marker(queue: Queue | PipelineQueue, debug_queue_name: str | None = None, stop_marker=STOP_MARKER):
    queue_name = queue.name if isinstance(queue, PipelineQueue) else debug_queue_name