@@ -10,8 +10,7 @@ def worker():
task = q.get()
logging.debug(f"Working on {task}")
job, callback = task
- job()
- callback()
+ job(callback)
logging.debug(f"Working on {task} done.")
q.task_done()
except Exception as e:
