From 54c1c4ac24c2c1370f360863a7affaa053a0e932 Mon Sep 17 00:00:00 2001 From: fatchan Date: Mon, 9 Sep 2019 17:48:43 +0000 Subject: [PATCH] return promise, remove done in worker not needed when returning promise --- worker.js | 9 ++++++--- 1 file changed, 6 insertions(+), 3 deletions(-) diff --git a/worker.js b/worker.js index e8430489..b2b4f011 100644 --- a/worker.js +++ b/worker.js @@ -16,9 +16,12 @@ const Queue = require('bull') const buildTasks = require(__dirname+'/helpers/build.js') , generateQueue = new Queue('generate', { 'redis': configs.redis }); - generateQueue.process(async (job, done) => { - await buildTasks[job.data.task](job.data.options); - done(); + generateQueue + .on('error', console.error) + .on('failed', console.warn); + + generateQueue.process(async job => { + return buildTasks[job.data.task](job.data.options); }); })();