From 201d4a8012373c1021eb44356b12d26bd2bf192a Mon Sep 17 00:00:00 2001 From: Carlos Tolon Date: Fri, 16 Feb 2024 12:21:35 +0100 Subject: [PATCH] Added end explicit end value when fetching Prometheus series --- pkg/custom-provider/provider.go | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/pkg/custom-provider/provider.go b/pkg/custom-provider/provider.go index 989042d5..61752c8a 100644 --- a/pkg/custom-provider/provider.go +++ b/pkg/custom-provider/provider.go @@ -238,6 +238,7 @@ type selectorSeries struct { func (l *cachingMetricsLister) updateMetrics() error { startTime := pmodel.Now().Add(-1 * l.maxAge) + endTime := pmodel.Now() // don't do duplicate queries when it's just the matchers that change seriesCacheByQuery := make(map[prom.Selector][]prom.Series) @@ -256,7 +257,7 @@ func (l *cachingMetricsLister) updateMetrics() error { } selectors[sel] = struct{}{} go func() { - series, err := l.promClient.Series(context.TODO(), pmodel.Interval{Start: startTime, End: 0}, sel) + series, err := l.promClient.Series(context.TODO(), pmodel.Interval{Start: startTime, End: endTime}, sel) if err != nil { errs <- fmt.Errorf("unable to fetch metrics for query %q: %v", sel, err) return