Rename filter and invert condition.

clean_failed_job_stacks.js

@@ -5,7 +5,7 @@ const sendToSlack = require('./utils/slack')(process.env.SLACK_WEBHOOK_URL, proc
 
 const sumArray = require('./utils/sumArray')
 const getFailedQueues = require('./utils/getFailedQueues')
-const getAttemptedJobs = require('./utils/jobsExceedingAttemptsFilter')
+const getJobsBelowAttemptLimit = require('./utils/jobsNotExceedingAttemptsFilter')
 
 console.log(`${new Date().toISOString()} - Checking for failed jobs in ${queueNames.join(', ')} queues`)
 
@@ -17,15 +17,15 @@ getFailedQueues(queueNames)
     .then(async queues => {
         const retriedJobCountsForEachQueue = await Promise.all(
             queues.map(async queue => {
-                const failedJobs = getAttemptedJobs(await queue.getFailed())
+                const failedJobsToRetry = getJobsBelowAttemptLimit(await queue.getFailed())
 
-                if (!failedJobs.length) {
+                if (!failedJobsToRetry.length) {
                     return queue.close().then(() => 0)
                 }
 
-                const failedCount = failedJobs.length
+                const failedCount = failedJobsToRetry.length
                 const retriedJobs = await pMap(
-                    failedJobs,
+                    failedJobsToRetry,
                     async job => {
                         const { id, data, opts } = job
                         opts.jobId = id

utils/jobsNotExceedingAttemptsFilter.js

@@ -0,0 +1,10 @@
+const MAX_FAILED_COUNT = Number.parseInt(process.env.MAX_FAILED_COUNT)
+
+module.exports = jobs => jobs.filter(job => {
+    if (job && typeof job === 'object') {
+        const max = (MAX_FAILED_COUNT || Number.parseInt(job.opts.attempts) || 100)
+        return job.attemptsMade < max
+    }
+    return false
+})
+