test

DataDog · Dec 12, 2024 · 2f8c3fe · 2f8c3fe
1 parent 3725fca
commit 2f8c3fe
Showing 1 changed file with 7 additions and 5 deletions.
diff --git a/datadog/dogstatsd/base.py b/datadog/dogstatsd/base.py
@@ -562,7 +562,7 @@ def _flush_thread_loop(self, flush_interval):
                 if not self._disable_aggregation:
                     self.flush_aggregated_metrics()
                     # Histograms, Distribution and Timing metrics are not aggregated
-                    self.flush_buffered_metrics()
+                    # self.flush_buffered_metrics()
                 if not self._disable_buffering:
                     self.flush_buffered_metrics()
         self._flush_thread = threading.Thread(
@@ -1129,10 +1129,12 @@ def _report(self, metric, metric_type, value, tags, sample_rate, timestamp=0):
         )
 
         # Send it
-        if metric_type in {MetricType.DISTRIBUTION, MetricType.HISTOGRAM, MetricType.TIMING}:
-            self._send_to_buffer(payload)
-        else:
-            self._send(payload)
+        # if metric_type in {MetricType.DISTRIBUTION, MetricType.HISTOGRAM, MetricType.TIMING}:
+        #     self._send_to_buffer(payload)
+        # else:
+        #     self._send(payload)
+
+        self._send(payload)
 
     def _reset_telemetry(self):
         self.metrics_count = 0