retryable_jobs_filter.rb

# frozen_string_literal: true

module Airbrake
  module Sidekiq
    # Internal: Airbrake filter that ignores exceptions from Sidekiq Jobs that
    # will be retried.
    class RetryableJobsFilter
      def call(notice)
        job = notice[:params][:job]

        notice.ignore! if retryable?(job)
      end

      private

      def retryable?(job)
        return false if job.nil? || job['retry'].nil?

        max_attempts = max_attempts_for(job)
        job['retry_count'] < max_attempts
      end

      def max_attempts_for(job)
        job['retry'].is_a?(Integer) ? job['retry'] : Sidekiq::JobRetry::DEFAULT_MAX_RETRY_ATTEMPTS
      end
    end
  end
end

Airbrake.add_filter(Airbrake::Sidekiq::RetryableJobsFilter.new)