lib/opentelemetry/instrumentation/que/instrumentation.rb in opentelemetry-instrumentation-que-0.2.0 vs lib/opentelemetry/instrumentation/que/instrumentation.rb in opentelemetry-instrumentation-que-0.3.0
- old
+ new
@@ -43,11 +43,11 @@
#
# Note that in all cases, we will store Que's Job ID as the
# `messaging.message_id` attribute, so out-of-band correlation may
# still be possible depending on your backend system.
#
- option :propagation_style, default: :link, validate: ->(opt) { %i[link child none].include?(opt) }
+ option :propagation_style, default: :link, validate: %i[link child none]
option :trace_poller, default: false, validate: :boolean
private
def require_dependencies
@@ -56,10 +56,10 @@
require_relative 'patches/que_job'
require_relative 'patches/poller'
end
def gem_version
- Gem.loaded_specs['que'].version
+ Gem::Version.new(::Que::VERSION)
end
def patch
::Que::Job.prepend(Patches::QueJob)
::Que::Poller.prepend(Patches::Poller)