class Sidekiq::Job::InterruptHandler

def call(instance, hash, queue)
  yield
rescue Interrupted
  logger.debug "Interrupted, re-queueing..."
  c = Sidekiq::Client.new
  c.push(hash)
  raise Sidekiq::JobRetry::Skip
end