Improved jobs exceeding max failed attempts filter.

SurveyLegend · Nov 23, 2020 · 719e705 · 719e705
1 parent 016c459
commit 719e705
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 2 deletions.
diff --git a/retry_failed_jobs.js b/retry_failed_jobs.js
@@ -10,7 +10,6 @@ const getAttemptedJobs = require('./utils/jobsExceedingAttemptsFilter')
 console.log(`${new Date().toISOString()} - Checking for failed jobs in ${queueNames.join(', ')} queues`)
 
 const CONCURRENCY = parseInt(process.env.CONCURRENCY) || 50
-const MAX_FAILED_COUNT = Number.parseInt(process.env.MAX_FAILED_COUNT) || 100
 
 const startTime = Date.now()
 

diff --git a/utils/jobsExceedingAttemptsFilter.js b/utils/jobsExceedingAttemptsFilter.js
@@ -1 +1,3 @@
-module.exports = jobs => jobs.filter(job => job && typeof job === 'object' && job.attemptsMade > (parseInt(process.env.MAX_FAILED_COUNT) || job.opts.attempts))
+const MAX_FAILED_COUNT = Number.parseInt(process.env.MAX_FAILED_COUNT)
+
+module.exports = jobs => jobs.filter(job => job && typeof job === 'object' && job.attemptsMade > (MAX_FAILED_COUNT || Number.parseInt(job.opts.attempts) || 100))