feat(telemetry): Add process tags to instrumentation telemetry

lib/datadog/core/telemetry/request.rb

@@ -1,6 +1,7 @@
 # frozen_string_literal: true
 
 require_relative '../environment/platform'
+require_relative '../environment/process'
 require_relative '../utils/hash'
 
 module Datadog
@@ -43,7 +44,7 @@ def application
               tracer_version = "#{tracer_version}-ci-#{::Datadog::CI::VERSION::STRING}"
             end
 
-            {
+            app = {
               env: config.env,
               language_name: Core::Environment::Ext::LANG,
               language_version: Core::Environment::Ext::LANG_VERSION,
@@ -53,6 +54,10 @@ def application
               service_version: config.version,
               tracer_version: tracer_version
             }
+
+            tag_process_tags!(app)
+
+            app
           end
 
           def host
@@ -64,6 +69,15 @@ def host
               kernel_version: Core::Environment::Platform.kernel_version
             }
           end
+
+          def tag_process_tags!(app)
+            return unless Datadog.configuration.experimental_propagate_process_tags_enabled
+
+            process_tags = Core::Environment::Process.serialized
+            return if process_tags.empty?
+
+            app[:process_tags] = process_tags
+          end
         end
       end
     end

sig/datadog/core/telemetry/request.rbs

@@ -8,6 +8,7 @@ module Datadog
 
         def self.application: -> ::Hash[Symbol, untyped]
         def self.host: -> ::Hash[Symbol, untyped]
+        def self.tag_process_tags!: (Hash[Symbol, untyped] app) -> void
       end
     end
   end

spec/datadog/core/telemetry/integration/telemetry_spec.rb

@@ -298,6 +298,59 @@
         )
       end
     end
+
+    describe 'process tags' do
+      include_context 'disable profiling'
+
+      before do
+        settings.telemetry.dependency_collection = true
+      end
+
+      context 'when process tags propagation is enabled' do
+        let(:expected_application_hash) do
+          super().merge('process_tags' => String)
+        end
+
+        it 'includes process tags in the payload when the process tags have values' do
+          allow(Datadog.configuration).to receive(:experimental_propagate_process_tags_enabled).and_return(true)
+
+          component.start(false, components: Datadog.send(:components))
+          component.flush
+          expect(sent_payloads.length).to eq 2
+
+          payload = sent_payloads[0]
+          expect(payload.fetch(:payload)).to match(
+            'api_version' => 'v2',
+            'application' => expected_application_hash,
+            'debug' => false,
+            'host' => expected_host_hash,
+            'payload' => Hash,
+            'request_type' => 'app-started',
+            'runtime_id' => String,
+            'seq_id' => Integer,
+            'tracer_time' => Integer,
+          )
+
+          expect(payload.dig(:payload, 'application', 'process_tags')).to include('entrypoint.workdir')
+          expect(payload.dig(:payload, 'application', 'process_tags')).to include('entrypoint.basedir')
+          expect(payload.dig(:payload, 'application', 'process_tags')).to include('entrypoint.type')
+          expect(payload.dig(:payload, 'application', 'process_tags')).to include('entrypoint.name')
+        end
+      end
+
+      context 'when process tags propagation is disabled' do
+        it 'does not include process_tags in the payload' do
+          allow(Datadog.configuration).to receive(:experimental_propagate_process_tags_enabled).and_return(false)
+
+          component.start(false, components: Datadog.send(:components))
+          component.flush
+          expect(sent_payloads.length).to eq 2
+
+          payload = sent_payloads[0]
+          expect(payload.dig(:payload, 'application')).not_to have_key('process_tags')
+        end
+      end
+    end
   end
 
   let(:handler_proc) do