To enable ActiveJob to control retry

active_job_retry_controlable.rb

module ActiveJobRetryControlable
  extend ActiveSupport::Concern

  DEFAULT_RETRY_LIMIT = 5

  class_methods do
    def retry_limit(retry_limit)
      @retry_limit = retry_limit
    end

    def load_retry_limit
      @retry_limit || DEFAULT_RETRY_LIMIT
    end
  end

  included do
    attr_reader :attempt_number

    def attempt_number
      @attempt_number || 0
    end

    def serialize
      super.merge("attempt_number" => attempt_number + 1)
    end

    def deserialize(job_data)
      super
      @attempt_number = (job_data["attempt_number"] || 1)
    end

    private

    def retry_limit
      self.class.load_retry_limit
    end

    def retry_limit_exceeded?
      self.class.load_retry_limit

      attempt_number > retry_limit
    end
  end
end