Function
empty_out_queue
(queue: Queue | PipelineQueue, debug_queue_name: str | None = None)
Source from the content-addressed store, hash-verified
| 78 | |
| 79 | |
| 80 | def empty_out_queue(queue: Queue | PipelineQueue, debug_queue_name: str | None = None): |
| 81 | queue_name = queue.name if isinstance(queue, PipelineQueue) else debug_queue_name |
| 82 | assert queue_name is not None |
| 83 | while not queue.empty(): |
| 84 | queue.get() |
| 85 | queue.task_done() |
| 86 | logger.debug(f"purged all remaining elements from queue {queue_name}") |
| 87 | |
| 88 | def empty_out_queue_until_producer_is_done(queue: PipelineQueue, producer_thread: Thread): |
| 89 | """ |
Callers
nothing calls this directly
Tested by
no test coverage detected