Contents

# typed: false
require 'ddtrace/ext/integration'
require 'ddtrace/contrib/analytics'
require 'ddtrace/contrib/active_job/ext'
require 'ddtrace/contrib/active_job/event'

module Datadog
  module Contrib
    module ActiveJob
      module Events
        # Defines instrumentation for enqueue.active_job event
        module RetryStopped
          include ActiveJob::Event

          EVENT_NAME = 'retry_stopped.active_job'.freeze

          module_function

          def event_name
            self::EVENT_NAME
          end

          def span_name
            Ext::SPAN_RETRY_STOPPED
          end

          def process(span, event, _id, payload)
            span.name = span_name
            span.service = configuration[:service_name]
            span.resource = payload[:job].class.name

            # Set analytics sample rate
            if Contrib::Analytics.enabled?(configuration[:analytics_enabled])
              Contrib::Analytics.set_sample_rate(span, configuration[:analytics_sample_rate])
            end

            set_common_tags(span, payload)
            span.set_tag(Ext::TAG_JOB_ERROR, payload[:error])
          rescue StandardError => e
            Datadog.logger.debug(e.message)
          end
        end
      end
    end
  end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
ddtrace-0.54.2	lib/ddtrace/contrib/active_job/events/retry_stopped.rb
ddtrace-0.54.1	lib/ddtrace/contrib/active_job/events/retry_stopped.rb
ddtrace-0.54.0	lib/ddtrace/contrib/active_job/events/retry_stopped.rb
ddtrace-0.53.0	lib/ddtrace/contrib/active_job/events/retry_stopped.rb