-
-
Save RafeHatfield/39bcd4d6ddb3ad207154 to your computer and use it in GitHub Desktop.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
module Cancelerizer | |
def cancel arg | |
Sidekiq::ScheduledSet.new.each do |job| | |
(klass, method, args) = YAML.load job.args.first | |
if self == klass and args.first == arg | |
job.delete | |
end | |
end | |
end | |
end |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
class SomeWorker | |
include Sidekiq::Worker | |
extend Cancelerizer | |
def self.delayed_something path | |
cancel path | |
delay_for( 2.minutes ).process path | |
end | |
def self.process path | |
puts "Processing #{path}" | |
end | |
end |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment