lib/sidekiq/api.rb in sidekiq-2.7.2 vs lib/sidekiq/api.rb in sidekiq-2.7.3

@@ -340,9 +340,15 @@
   #   end.map(&:delete)
   class RetrySet < SortedSet
     def initialize
       super 'retry'
     end
+
+    def retry_all
+      while size > 0
+        each(&:retry)
+      end
+    end
   end
 
 
   ##
   # Programmatic access to the current active worker set.