Compare commits
2 commits
83bce62672
...
c504091c61
Author | SHA1 | Date | |
---|---|---|---|
c504091c61 | |||
aac1c40657 |
1 changed files with 10 additions and 2 deletions
|
@ -58,8 +58,16 @@ deliverQueue
|
|||
await deletionRefCount(job);
|
||||
})
|
||||
.on('failed', async (job, err) => {
|
||||
deliverLogger.warn(`failed(${err}) ${getJobInfo(job)} to=${job.data.to}`);
|
||||
await deletionRefCount(job);
|
||||
if (err.type === 'aborted') {
|
||||
deliverLogger.debug(`failed(${err}) ${getJobInfo(job)} to=${job.data.to}`);
|
||||
} else {
|
||||
deliverLogger.warn(`failed(${err}) ${getJobInfo(job)} to=${job.data.to}`);
|
||||
}
|
||||
|
||||
if (job.attemptsMade >= (job.opts?.attempts ?? 1)) {
|
||||
// this was the last attempt
|
||||
await deletionRefCount(job);
|
||||
}
|
||||
})
|
||||
.on('error', (job: any, err: Error) => deliverLogger.error(`error ${err}`))
|
||||
.on('stalled', (job) => deliverLogger.warn(`stalled ${getJobInfo(job)} to=${job.data.to}`));
|
||||
|
|
Loading…
Add table
Reference in a new issue