Contents

require 'sentry/sidekiq/context_filter'

module Sentry
  module Sidekiq
    class ErrorHandler
      def call(ex, context)
        return unless Sentry.initialized?

        context_filter = Sentry::Sidekiq::ContextFilter.new(context)

        scope = Sentry.get_current_scope
        scope.set_transaction_name(context_filter.transaction_name) unless scope.transaction_name

        if Sentry.configuration.sidekiq.report_after_job_retries && retryable?(context)
          retry_count = context.dig(:job, "retry_count")
          if retry_count.nil? || retry_count < retry_limit(context) - 1
            return
          end
        end

        Sentry::Sidekiq.capture_exception(
          ex,
          contexts: { sidekiq: context_filter.filtered },
          hint: { background: false }
        )
      end

      private

      def retryable?(context)
        retry_option = context.dig(:job, "retry")
        # when `retry` is not specified, it's default is `true` and it means 25 retries.
        retry_option == true || (retry_option.is_a?(Integer) && retry_option.positive?)
      end

      def retry_limit(context)
        limit = context.dig(:job, "retry")

        case limit
        when Integer
          limit
        when TrueClass
          ::Sidekiq.options[:max_retries] || 25
        else
          0
        end
      end
    end
  end
end

Version data entries

10 entries across 10 versions & 1 rubygems

Version	Path
sentry-sidekiq-5.4.2	lib/sentry/sidekiq/error_handler.rb
sentry-sidekiq-5.4.1	lib/sentry/sidekiq/error_handler.rb
sentry-sidekiq-5.4.0	lib/sentry/sidekiq/error_handler.rb
sentry-sidekiq-5.3.1	lib/sentry/sidekiq/error_handler.rb
sentry-sidekiq-5.3.0	lib/sentry/sidekiq/error_handler.rb
sentry-sidekiq-5.2.1	lib/sentry/sidekiq/error_handler.rb
sentry-sidekiq-5.2.0	lib/sentry/sidekiq/error_handler.rb
sentry-sidekiq-5.1.1	lib/sentry/sidekiq/error_handler.rb
sentry-sidekiq-5.1.0	lib/sentry/sidekiq/error_handler.rb
sentry-sidekiq-5.0.2	lib/sentry/sidekiq/error_handler.rb