@@ -117,6 +117,7 @@ def process_queue_with_threads():
try:
item = queue.get(False)
thread = Thread(target=process_segment, args=(item,))
+ threads[index] = thread
thread.start()
except Empty:
is_drained = True