Skip to content

Commit ca0ba27

Browse files
committed
fix test
Signed-off-by: Ben Ye <[email protected]>
1 parent 3bf0138 commit ca0ba27

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

pkg/distributor/distributor.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -582,7 +582,7 @@ func (d *Distributor) validateSeries(ts cortexpb.PreallocTimeseries, userID stri
582582
for _, h := range ts.Histograms {
583583
// TODO(yeya24): add other validations for native histogram.
584584
// For example, Prometheus scrape has bucket limit and schema check.
585-
if err := validation.ValidateSampleTimestamp(limits, userID, ts.Labels, h.TimestampMs); err != nil {
585+
if err := validation.ValidateSampleTimestamp(d.validateMetrics, limits, userID, ts.Labels, h.TimestampMs); err != nil {
586586
return emptyPreallocSeries, err
587587
}
588588
}

pkg/ingester/ingester_test.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2453,7 +2453,7 @@ func TestIngester_QueryStream(t *testing.T) {
24532453

24542454
for _, enc := range encodings {
24552455
t.Run(enc.String(), func(t *testing.T) {
2456-
i, err := prepareIngesterWithBlocksStorage(t, cfg, nil)
2456+
i, err := prepareIngesterWithBlocksStorage(t, cfg, prometheus.NewRegistry())
24572457
require.NoError(t, err)
24582458
require.NoError(t, services.StartAndAwaitRunning(context.Background(), i))
24592459
defer services.StopAndAwaitTerminated(context.Background(), i) //nolint:errcheck

0 commit comments

Comments
 (0)