# 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 perform.active_job event module Perform include ActiveJob::Event EVENT_NAME = 'perform.active_job'.freeze module_function def event_name self::EVENT_NAME end def span_name Ext::SPAN_PERFORM 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_PERFORM) # 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) rescue StandardError => e Datadog.logger.debug(e.message) end end end end end end end