From 78ce1463d99d9d8f58aae21ddd4a5f3125b9ff28 Mon Sep 17 00:00:00 2001 From: andrewqian2001datadog Date: Mon, 22 Jul 2024 15:22:52 -0400 Subject: [PATCH] finish disabling aggregation functions --- datadog/dogstatsd/base.py | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/datadog/dogstatsd/base.py b/datadog/dogstatsd/base.py index 1129037e2..2b6766b6e 100644 --- a/datadog/dogstatsd/base.py +++ b/datadog/dogstatsd/base.py @@ -666,12 +666,11 @@ def disable_aggregation(self, is_disabled): # If aggregation has been disabled, flush and kill the background thread # otherwise start up the flushing thread and enable aggregation. + self._send = self._send_to_server if is_disabled: - self._send = self._send_to_server self._stop_aggregation_flush_thread() log.debug("Statsd aggregation is disabled") else: - self._send = self._send_to_aggregator self._start_flush_thread(self._aggregation_flush_interval, MIN_AGGREGATION_FLUSH_INTERVAL, self.flush_aggregated_metrics, self._aggregation_flush_thread, self._aggregation_flush_thread_stop)