class Sidekiq::ScheduledSet

Overview

Allows enumeration of scheduled jobs 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::ScheduledSet.new r.select do |retri| retri.klass == "Sidekiq::Extensions::DelayedClass" && retri.args[0] == "User" && retri.args[1] == "setup_new_subscriber" end.map(&:delete)

Defined in:

sidekiq/api.cr

Constructors

Instance methods inherited from class Sidekiq::JobSet

delete_by_jid(score, jid) delete_by_jid, delete_by_value(name, value) delete_by_value, each(&) each, fetch(score, jid = nil) fetch, find_job(jid) find_job, schedule(timestamp, json_message : String) schedule

Instance methods inherited from class Sidekiq::SortedSet

clear clear, name : String name, size size

Constructor methods inherited from class Sidekiq::SortedSet

new(name : String) new

Constructor Detail

def self.new #

[View source]