I've setup a bee-queue with arena and In my local machine when I call
queue.process(async function (job, done) {
console.log(`Processing job ${job.id}`);
job.reportProgress(5);
let res = await my_service.execute(job);
if(res.status) {
//report job progress
job.reportProgress(100);
return done(null, res.msg);
} else {
done(new Error(res.msg));
}
});
I see on my flow that the done(new Error(res.msg)); is being called and I also debugged the done function and I see it rejects the promise. however when I look at the job on Arena I see it in success section
RetroSearch is an open source project built by @garambo | Open a GitHub Issue
Search and Browse the WWW like it's 1997 | Search results from DuckDuckGo
HTML:
3.2
| Encoding:
UTF-8
| Version:
0.7.4