Check MAX_FAILED_COUNT in jobExceedingAttemptsFilter to enable cleani…

…ng stacks for jobs with fewer attempts than job.opts.attempts.
SurveyLegend · Aug 22, 2020 · fde479a · fde479a
1 parent b220aa3
commit fde479a
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 2 deletions.
diff --git a/retry_failed_jobs.js b/retry_failed_jobs.js
@@ -19,7 +19,6 @@ getFailedQueues(queueNames)
         const retriedJobCountsForEachQueue = await Promise.all(
             queues.map(async queue => {
                 const failedJobs = getAttemptedJobs(await queue.getFailed())
-                    .filter(job => job.attemptsMade > MAX_FAILED_COUNT)
 
                 if (!failedJobs.length) {
                     return queue.close().then(() => 0)

diff --git a/utils/jobsExceedingAttemptsFilter.js b/utils/jobsExceedingAttemptsFilter.js
@@ -1 +1 @@
-module.exports = jobs => jobs.filter(job => job && typeof job === 'object' && job.attemptsMade > job.opts.attempts)
+module.exports = jobs => jobs.filter(job => job && typeof job === 'object' && job.attemptsMade > (parseInt(process.env.MAX_FAILED_COUNT) || job.opts.attempts))
Original file line number	Diff line number	Diff line change
		@@ -1 +1 @@
		module.exports = jobs => jobs.filter(job => job && typeof job === 'object' && job.attemptsMade > job.opts.attempts)
		module.exports = jobs => jobs.filter(job => job && typeof job === 'object' && job.attemptsMade > (parseInt(process.env.MAX_FAILED_COUNT) \|\| job.opts.attempts))