Double adaptive sampling when core tracing is on

Author: hmstepanek

newrelic/core/application.py

@@ -507,7 +507,11 @@ def connect_to_data_collector(self, activate_agent):
                 sampling_target_period = 60.0
             else:
                 sampling_target_period = configuration.sampling_target_period_in_seconds
-            self.adaptive_sampler = AdaptiveSampler(configuration.sampling_target, sampling_target_period)
+            sampling_target = configuration.sampling_target
+            # If CT is enabled double the transaction reservoir size.
+            if configuration.core_tracing.enabled:
+                sampling_target = configuration.sampling_target*2
+            self.adaptive_sampler = AdaptiveSampler(sampling_target, sampling_target_period)
 
         active_session.connect_span_stream(self._stats_engine.span_stream, self.record_custom_metric)
 
@@ -1367,6 +1371,7 @@ def harvest(self, shutdown=False, flexible=False):
 
                                 internal_count_metric("Supportability/InfiniteTracing/Span/Seen", spans_seen)
                                 internal_count_metric("Supportability/InfiniteTracing/Span/Sent", spans_sent)
+                                print(f"spans sent: {spans_sent}")
                                 internal_count_metric("Supportability/InfiniteTracing/Bytes/Seen", _bytes)
                                 internal_count_metric("Supportability/CoreTracing/TotalTime", ct_processing_time*1000)  # Time in ms.
                         else:
@@ -1385,6 +1390,7 @@ def harvest(self, shutdown=False, flexible=False):
                                 spans_sampled = spans.num_samples
                                 internal_count_metric("Supportability/SpanEvent/TotalEventsSeen", spans_seen)
                                 internal_count_metric("Supportability/SpanEvent/TotalEventsSent", spans_sampled)
+                                print(f"spans sent: {spans_sampled}")
                                 internal_count_metric("Supportability/DistributedTracing/Bytes/Seen", spans.bytes)
                                 internal_count_metric("Supportability/SpanEvent/TotalCoreTracingTime", spans.ct_processing_time*1000)  # Time in ms.