class Sidekiq::RetrySet
end.map(&:delete)<br>retri.args == ‘setup_new_subscriber’<br>retri.args == ‘User’ &&
retri.klass == ‘Sidekiq::Extensions::DelayedClass’ &&
r.select do |retri|
r = Sidekiq::RetrySet.new
and deleting them from the retry queue.
example where I’m selecting all jobs of a certain type
Based on this, you can search/filter for jobs. Here’s an
Allows enumeration of retries within Sidekiq.
#
def initialize
def initialize super 'retry' end