I also dont get fail event

queue.on("failed", (job, err) => {
console.log(Job ${job.id} failed with error ${err.message});
});

@sharonass I think the problem is that if you pass an async function (or a promise) the done callback will be useless

See docs:

N.B. If the handler returns a Promise, calls to the done callback will be ignored.

https://github.com/bee-queue/bee-queue#queueprocessconcurrency-handlerjob-done

Aha, I was a bit puzzled here but @dylanjha I think you hit the nail on the head.

I would replace:

return done(null, res.msg);
...
done(new Error(res.msg));

with:

return res.msg;
...
throw new Error(res.msg);