Recurring job scheduling with ActiveJob

example_job.rb

class ExampleJob < Job
  schedule every: 30.minutes,
           wait_until: Time.now.tomorrow.midnight
end

job.rb

class Job < ActiveJob::Base
  cattr_accessor :offline

  after_perform do |job|
    if self.class.recurring?
      self.class.schedule
      say("Scheduling another job in #{self.class.run_interval.inspect}")
    end
  end

  private

    def say(message)
      ::Job.log.info("[#{self.class.name}] #{message}")
    end

  class << self

    attr_reader :run_interval

    def schedule(options = {}, &block)
      @run_interval = options.fetch(:every, nil)
      schedule!(options, &block) unless offline? or already_scheduled?
    end

    def schedule!(options = {}, &block)
      if options.has_key? :wait_until
        self.set(options.slice(:wait_until)).perform_later
      elsif recurring?
        self.set(wait: run_interval).perform_later
      else
        self.perform_later
      end
    end

    def offline?
      Job.offline
    end

    def already_scheduled?
      begin
        Sidekiq::ScheduledSet.new.select do |job|
          return true if job.display_class == self.name
        end.any?
      rescue Redis::CannotConnectError, SocketError
        Job.offline = true
        true
      end
    end

    def recurring?
      @run_interval.present?
    end

    def log
      @logger ||= begin
        logger = ::Logger.new(Rails.root.join('log', 'job.log').to_s)
        logger.formatter = proc { |s, d, p, m| "[#{d}]#{m}\n" }
        logger
      end
    end
  end
end