Sidekiq::JidStorage

cancelable.rb

require 'active_support/concern'

module Sidekiq::Cancelable
  extend ActiveSupport::Concern

  included do
    include Redis::Objects

    attr_accessor :id
    value :stored_jid

    def self.perform_at(timestamp, *args)
      stored_jid = super(timestamp, *args)
      worker    = self.new
      worker.id = args.first.id
      worker.stored_jid = stored_jid
    end

    def self.cancel!(schedulable)
      worker    = self.new
      worker.id = schedulable.id
      cancel_by_jid(worker.stored_jid)
    end

    def self.cancel_by_jid(jid)
      Sidekiq.redis { |c| c.setex("cancelled-#{jid}", 86400, 1) }
    end

    def cancelled?
      Sidekiq.redis { |c| c.exists("cancelled-#{jid}") }
    end
  end
end

main.rb

Notifications::Scheduler.cancel!(job)

scheduler.rb

module Notifications
  class Scheduler
    include Sidekiq::Worker
    include Sidekiq::Cancelable
    sidekiq_options retry: false, queue: 'session_notifications'

    def perform(job_id)
      job = Job.find(job_id)
      Notification::SessionNotifier.send_reminder!(job)
    end
  end
end