Allows configuration of the Dead Job Queue.

Changes.md

@@ -1,3 +1,7 @@
+3.3.2 (unreleased)
+-----------
+- Allows configuration of dead job set size and timeout
+
 3.3.1
 -----------
 

lib/sidekiq.rb

@@ -25,7 +25,9 @@ module Sidekiq
       startup: [],
       quiet: [],
       shutdown: [],
-    }
+    },
+    dead_max_jobs: 10_000,
+    dead_timeout_in_seconds: 180 * 24 * 60 * 60 # 6 months
   }
 
   def self.❨╯°□°❩╯︵┻━┻

lib/sidekiq/api.rb

@@ -399,8 +399,8 @@ def kill
         Sidekiq.redis do |conn|
           conn.multi do
             conn.zadd('dead', now, message)
-            conn.zremrangebyscore('dead', '-inf', now - DeadSet::TIMEOUT)
-            conn.zremrangebyrank('dead', 0, - DeadSet::MAX_JOBS)
+            conn.zremrangebyscore('dead', '-inf', now - DeadSet.timeout)
+            conn.zremrangebyrank('dead', 0, - DeadSet.max_jobs)
           end
         end
       end
@@ -593,9 +593,6 @@ def retry_all
   # Allows enumeration of dead jobs within Sidekiq.
   #
   class DeadSet < JobSet
-    TIMEOUT = 180 * 24 * 60 * 60 # 6 months
-    MAX_JOBS = 10_000
-
     def initialize
       super 'dead'
     end
@@ -605,6 +602,14 @@ def retry_all
         each(&:retry)
       end
     end
+
+    def self.max_jobs
+      Sidekiq.options[:dead_max_jobs]
+    end
+
+    def self.timeout
+      Sidekiq.options[:dead_timeout_in_seconds]
+    end
   end
 
   ##

lib/sidekiq/middleware/server/retry_jobs.rb

@@ -156,8 +156,8 @@ def send_to_morgue(msg)
           Sidekiq.redis do |conn|
             conn.multi do
               conn.zadd('dead', now, payload)
-              conn.zremrangebyscore('dead', '-inf', now - DeadSet::TIMEOUT)
-              conn.zremrangebyrank('dead', 0, -DeadSet::MAX_JOBS)
+              conn.zremrangebyscore('dead', '-inf', now - DeadSet.timeout)
+              conn.zremrangebyrank('dead', 0, -DeadSet.max_jobs)
             end
           end
         end