Searched refs:worker_flush (Results 1 – 1 of 1) sorted by relevance
93 def worker_flush(worker_queue): function115 worker_thread = Thread(target=worker_flush, args=(worker_queue,))