Added env variable MAX_FAILED_COUNT and set sane default value of 100.

SurveyLegend · Jul 23, 2020 · 94d9c36 · 94d9c36
1 parent d5d0488
commit 94d9c36
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 0 deletions.
diff --git a/.env.example b/.env.example
@@ -7,5 +7,7 @@ REDIS_DATABASE=0
 #REDIS_PASS=
 #REDIS_TLS=true
 
+MAX_FAILED_COUNT=100
+
 SLACK_WEBHOOK_URL=https://hooks.slack.com/services/...
 SLACK_CHANNEL="#my-channel"
diff --git a/retry_failed_jobs.js b/retry_failed_jobs.js
@@ -12,6 +12,7 @@ const REDIS_HOST = process.env.REDIS_HOST || '127.0.0.1'
 const REDIS_DATABASE = Number.parseInt(process.env.REDIS_DATABASE) || 0
 const REDIS_PASS = process.env.REDIS_PASS
 const REDIS_TLS = process.env.REDIS_TLS && `${process.env.REDIS_TLS}` === 'true'
+const MAX_FAILED_COUNT = Number.parseInt(process.env.MAX_FAILED_COUNT) || 100
 
 const REDIS_CONFIG = {
     redis: {
@@ -48,6 +49,9 @@ forEach(args, async (name, index) => {
 
         const jobs = await queue.getFailed()
         const retriedJobCount = await reduce(jobs, async (count, job) => {
+            if (job.attemptsMade > MAX_FAILED_COUNT) {
+                return result
+            }
             try {
                 await job.retry()
                 count++