diff --git a/worker.js b/worker.js index 958d14b6..9f5cdcf4 100644 --- a/worker.js +++ b/worker.js @@ -21,7 +21,8 @@ const Queue = require('bull') .on('failed', console.warn); taskQueue.process(async job => { - return tasks[job.data.task](job.data.options); + await tasks[job.data.task](job.data.options); + return null; }); })();