Skip to content

Instantly share code, notes, and snippets.

@RafeHatfield
Forked from smathy/cancelerizer.rb
Last active August 29, 2015 14:06
Show Gist options
  • Save RafeHatfield/39bcd4d6ddb3ad207154 to your computer and use it in GitHub Desktop.
Save RafeHatfield/39bcd4d6ddb3ad207154 to your computer and use it in GitHub Desktop.
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
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