lst_auto_rta.utils.queue

Functions

get_all_non_blocking(q)

Get all items present in the queue, non-blocking.

process_all_items(q, processed_items, ...)

Empty q and apply process_item_fct on all items not in processed_items with kwargs from process_item_fct_extra_kwargs