@@ -22,6 +22,7 @@ def worker():
def init_workers(count=2):
logging.info("Initializing workers...")
+ global q
q = queue.Queue()
for _ in range(count):
threading.Thread(target=worker).start()