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