Class: Sidekiq::RetrySet

Inherits:

Object
SortedSet
JobSet
Sidekiq::RetrySet

Defined in:: lib/sidekiq/api.rb

Overview

Allows enumeration of retries within Sidekiq. Based on this, you can search/filter for jobs. Here’s an example where I’m selecting all jobs of a certain type and deleting them from the retry queue.

r = Sidekiq::RetrySet.new
r.select do |retri|
  retri.klass == 'Sidekiq::Extensions::DelayedClass' &&
  retri.args[0] == 'User' &&
  retri.args[1] == 'setup_new_subscriber'
end.map(&:delete)

Instance Attribute Summary

Attributes inherited from SortedSet

#name

Instance Method Summary collapse

#initialize ⇒ RetrySet constructor

A new instance of RetrySet.
#retry_all ⇒ Object

Methods inherited from JobSet

#delete, #each, #fetch, #find_job, #schedule

Methods inherited from SortedSet

#clear, #size

Constructor Details

#initialize ⇒ `RetrySet`

Returns a new instance of RetrySet.



508
509
510

# File 'lib/sidekiq/api.rb', line 508

def initialize
  super 'retry'
end

Instance Method Details

#retry_all ⇒ `Object`

# File 'lib/sidekiq/api.rb', line 512

def retry_all
  while size > 0
    each(&:retry)
  end
end