fix: stop error

JoyfulProgramming · Jun 9, 2024 · 540d02d · 540d02d
1 parent 2230e8a
commit 540d02d
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 2 deletions.
diff --git a/...sidekiq/lib/opentelemetry/instrumentation/sidekiq/middlewares/server/tracer_middleware.rb b/...sidekiq/lib/opentelemetry/instrumentation/sidekiq/middlewares/server/tracer_middleware.rb
@@ -38,8 +38,7 @@ def call(worker, msg, _queue)
                 'com.joyful_programming.messaging.message.created_at' => msg['created_at'],
                 'com.joyful_programming.messaging.message.enqueued_at' => msg['enqueued_at'],
                 'com.joyful_programming.messaging.message.failed_at' => msg['failed_at'],
-                'com.joyful_programming.messaging.message.retried_at' => msg['retried_at'],
-                'com.joyful_programming.messaging.message.retries.dead_queue_enabled' => worker.sidekiq_options_hash['dead'] || true
+                'com.joyful_programming.messaging.message.retried_at' => msg['retried_at']
               }.compact
               attributes[SemanticConventions::Trace::PEER_SERVICE] = instrumentation_config[:peer_service] if instrumentation_config[:peer_service]
 

diff --git a/instrumentation/sidekiq/opentelemetry-instrumentation-sidekiq.gemspec b/instrumentation/sidekiq/opentelemetry-instrumentation-sidekiq.gemspec
@@ -38,6 +38,7 @@ Gem::Specification.new do |spec|
   spec.add_development_dependency 'rspec-mocks'
   spec.add_development_dependency 'rubocop', '~> 1.62'
   spec.add_development_dependency 'rubocop-performance', '~> 1.20'
+  spec.add_development_dependency 'sidekiq'
   spec.add_development_dependency 'simplecov', '~> 0.17.1'
   spec.add_development_dependency 'yard', '~> 0.9'
 

diff --git a/instrumentation/sidekiq/test/test_helper.rb b/instrumentation/sidekiq/test/test_helper.rb
@@ -11,6 +11,7 @@
 
 require 'minitest/autorun'
 require 'rspec/mocks/minitest_integration'
+require 'sidekiq'
 require 'sidekiq/testing'
 
 if Gem::Version.new(Sidekiq::VERSION) >= Gem::Version.new('7.0.0')