Sha256: 6009f694d0c1c4796adedf23e4694d7573f985adc866478de32c81a15955174b
Contents?: true
Size: 1.49 KB
Versions: 12
Compression:
Stored size: 1.49 KB
Contents
# typed: false require_relative '../../../metadata/ext' require_relative '../../analytics' require_relative '../ext' require_relative '../event' module Datadog module Tracing module Contrib module ActiveJob module Events # Defines instrumentation for enqueue_retry.active_job event module EnqueueRetry include ActiveJob::Event EVENT_NAME = 'enqueue_retry.active_job'.freeze module_function def event_name self::EVENT_NAME end def span_name Ext::SPAN_ENQUEUE_RETRY end def process(span, event, _id, payload) span.name = span_name span.service = configuration[:service_name] if configuration[:service_name] span.resource = payload[:job].class.name span.set_tag(Tracing::Metadata::Ext::TAG_OPERATION, Ext::TAG_OPERATION_ENQUEUE_RETRY) # 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]) span.set_tag(Ext::TAG_JOB_RETRY_WAIT, payload[:wait]) rescue StandardError => e Datadog.logger.debug(e.message) end end end end end end end
Version data entries
12 entries across 12 versions & 1 rubygems