@@ -1116,25 +1116,6 @@ def test_aggregation_buffering_simultaneously_with_interval(self):
11161116 fake_socket .recv (2 , no_wait = True )
11171117 )
11181118
1119- def test_buffered_metric_aggregation (self ):
1120- dogstatsd = DogStatsd (disable_buffering = True , disable_aggregation = False , telemetry_min_flush_interval = 0 )
1121- fake_socket = FakeSocket ()
1122- dogstatsd .socket = fake_socket
1123- dogstatsd .histogram ("test.histogram_aggregation" , 1 )
1124- dogstatsd .distribution ("test.distribution_aggregation" , 2 )
1125- dogstatsd .timing ("test.timing_aggregation" , 3 )
1126- dogstatsd ._start_flush_thread ()
1127- time .sleep (dogstatsd ._flush_interval / 2 )
1128- # Ensure that packets didn't arrive immediately for buffered_metrics
1129- self .assertIsNone (dogstatsd .socket .recv (2 , no_wait = True ))
1130-
1131- time .sleep (dogstatsd ._flush_interval )
1132- packet = dogstatsd .socket .recv (2 , no_wait = True )
1133- h_metric = "test.histogram_aggregation:1|h"
1134- d_metric = "test.distribution_aggregation:2|d"
1135- t_metric = "test.timing_aggregation:3|ms"
1136- self .assertTrue (h_metric in packet and d_metric in packet and t_metric in packet )
1137-
11381119 def test_disable_buffering (self ):
11391120 dogstatsd = DogStatsd (disable_buffering = True , telemetry_min_flush_interval = 0 )
11401121 fake_socket = FakeSocket ()
0 commit comments