@@ -116,7 +116,7 @@ def process_queue_with_threads():
if not t:
try:
item = queue.get(False)
- thread = Thread(process_segment, args=(item,))
+ thread = Thread(target=process_segment, args=(item,))
thread.start()
except Empty:
is_drained = True