diff --git a/pkg/streamingpromql/engine_concurrency_test.go b/pkg/streamingpromql/engine_concurrency_test.go index 11217b2693..29ff3de990 100644 --- a/pkg/streamingpromql/engine_concurrency_test.go +++ b/pkg/streamingpromql/engine_concurrency_test.go @@ -42,7 +42,6 @@ func TestConcurrentQueries(t *testing.T) { testCases := []concurrentQueryTestCase{ { - // Rate over native histogram expr: `rate(native_histogram[5m])`, start: startT, end: startT.Add(10 * time.Minute), @@ -62,6 +61,24 @@ func TestConcurrentQueries(t *testing.T) { end: startT.Add(10 * time.Minute), step: time.Minute, }, + { + expr: `count_over_time(native_histogram[5m])`, + start: startT, + end: startT.Add(10 * time.Minute), + step: time.Minute, + }, + { + expr: `sum_over_time(native_histogram[5m])`, + start: startT, + end: startT.Add(10 * time.Minute), + step: time.Minute, + }, + { + expr: `avg_over_time(native_histogram[5m])`, + start: startT, + end: startT.Add(10 * time.Minute), + step: time.Minute, + }, } storage := promqltest.LoadedStorage(t, data)