Adds 'span.kind' tag with value consumer for resque

DataDog · Nov 22, 2022 · 7699a18 · 7699a18
1 parent 0195412
commit 7699a18
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 0 deletions.
diff --git a/lib/datadog/tracing/contrib/resque/resque_job.rb b/lib/datadog/tracing/contrib/resque/resque_job.rb
@@ -41,6 +41,8 @@ def around_perform0_ddtrace(*args)
               span.set_tag(Tracing::Metadata::Ext::TAG_COMPONENT, Ext::TAG_COMPONENT)
               span.set_tag(Tracing::Metadata::Ext::TAG_OPERATION, Ext::TAG_OPERATION_JOB)
 
+              span.set_tag(Tracing::Metadata::Ext::TAG_KIND, Tracing::Metadata::Ext::SpanKind::TAG_CONSUMER)
+
               # Set analytics sample rate
               if Contrib::Analytics.enabled?(datadog_configuration[:analytics_enabled])
                 Contrib::Analytics.set_sample_rate(span, datadog_configuration[:analytics_sample_rate])

diff --git a/spec/datadog/tracing/contrib/resque/instrumentation_spec.rb b/spec/datadog/tracing/contrib/resque/instrumentation_spec.rb
@@ -71,6 +71,7 @@ def perform_job(klass, *args)
         expect(span).to_not have_error
         expect(span.get_tag(Datadog::Tracing::Metadata::Ext::TAG_COMPONENT)).to eq('resque')
         expect(span.get_tag(Datadog::Tracing::Metadata::Ext::TAG_OPERATION)).to eq('job')
+        expect(span.get_tag('span.kind')).to eq('consumer')
       end
 
       it_behaves_like 'analytics for integration' do
@@ -119,6 +120,7 @@ def perform_job(klass, *args)
         expect(span).to have_error_type(error_class_name)
         expect(span.get_tag(Datadog::Tracing::Metadata::Ext::TAG_COMPONENT)).to eq('resque')
         expect(span.get_tag(Datadog::Tracing::Metadata::Ext::TAG_OPERATION)).to eq('job')
+        expect(span.get_tag('span.kind')).to eq('consumer')
       end
 
       context 'with custom error handler' do