squash: skip incompatible versions

open-telemetry · Jan 7, 2025 · f5408aa · f5408aa
1 parent c597ab2
commit f5408aa
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 0 deletions.
diff --git a/instrumentation/rdkafka/test/opentelemetry/instrumentation/rdkafka/patches/consumer_test.rb b/instrumentation/rdkafka/test/opentelemetry/instrumentation/rdkafka/patches/consumer_test.rb
@@ -33,6 +33,8 @@
 
     describe '#each' do
       it 'traces each call' do
+        skip "#{Rdkafka::VERSION} is not supported" unless instrumentation.installed?
+
         rand_hash = SecureRandom.hex(10)
         topic_name = "consumer-patch-trace-#{rand_hash}"
         config = { 'bootstrap.servers': "#{host}:#{port}" }
@@ -112,6 +114,8 @@
       end
 
       it 'encodes messages keys depending on input format' do
+        skip "#{Rdkafka::VERSION} is not supported" unless instrumentation.installed?
+
         rand_hash = SecureRandom.hex(10)
         topic_name = "consumer-patch-trace-#{rand_hash}"
         config = { 'bootstrap.servers': "#{host}:#{port}" }
@@ -164,6 +168,8 @@
 
     describe '#each_batch' do
       it 'traces each_batch call' do
+        skip "#{Rdkafka::VERSION} is not supported" unless instrumentation.installed?
+
         rand_hash = SecureRandom.hex(10)
         topic_name = "consumer-patch-batch-trace-#{rand_hash}"
         config = { 'bootstrap.servers': "#{host}:#{port}" }

diff --git a/instrumentation/rdkafka/test/opentelemetry/instrumentation/rdkafka/patches/producer_test.rb b/instrumentation/rdkafka/test/opentelemetry/instrumentation/rdkafka/patches/producer_test.rb
@@ -32,6 +32,7 @@
 
     describe 'tracing' do
       it 'traces sync produce calls' do
+        skip "#{Rdkafka::VERSION} is not supported" unless instrumentation.installed?
         topic_name = 'producer-patch-trace'
         config = { 'bootstrap.servers': "#{host}:#{port}" }