test(sidekiq): verify outgoing headers without propagation

Author: solnic

sentry-sidekiq/spec/isolated/active_job_spec.rb

@@ -645,6 +645,36 @@ def enqueue_and_process(adapter_skipped:)
     context "with sidekiq propagate_traces = false" do
       before { Sentry.configuration.sidekiq.propagate_traces = false }
 
+      context "when the job generates outgoing trace headers" do
+        let(:parity_job) do
+          stub_const("PropagatingParityJob", Class.new(ActiveJob::Base) do
+            self.queue_adapter = :sidekiq
+            queue_as :events
+
+            def perform(*)
+              Sentry.capture_message("outgoing headers", extra: { headers: Sentry.get_trace_propagation_headers })
+            end
+          end)
+        end
+
+        it "uses the new consumer transaction's trace without changing the propagation setting" do
+          enqueued = enqueue(adapter_skipped: false)
+
+          expect(enqueued.pushed_job).not_to have_key("trace_propagation_headers")
+          expect(enqueued.pushed_job["args"].first.dig("_sentry", "trace_propagation_headers")).to be_nil
+
+          events = process(enqueued.pushed_job, adapter_skipped: false)
+          transaction = consumer_transactions(events).first
+          event = events.grep(Sentry::ErrorEvent).find { |entry| entry.message == "outgoing headers" }
+          headers = event.extra[:headers]
+          consumer_trace_id = transaction.contexts.dig(:trace, :trace_id)
+
+          expect(consumer_trace_id).not_to eq(enqueued.parent.trace_id)
+          expect(headers["sentry-trace"].split("-").first).to eq(consumer_trace_id)
+          expect(headers["baggage"]).to include("sentry-trace_id=#{consumer_trace_id}")
+        end
+      end
+
       it "starts a new trace for the job whether the adapter is skipped or not" do
         [true, false].each do |adapter_skipped|
           enqueued, transaction = enqueue_and_process(adapter_skipped: adapter_skipped)