add context cancellation checks on GetSeries

Signed-off-by: Erlan Zholdubai uulu <[email protected]>

Author: erlan-z

pkg/querier/distributor_queryable.go

@@ -136,12 +136,7 @@ func (q *distributorQuerier) Select(ctx context.Context, sortSeries bool, sp *st
 		if err != nil {
 			return storage.ErrSeriesSet(err)
 		}
-		seriesSet, err := series.MetricsToSeriesSet(ctx, sortSeries, ms)
-		if err != nil {
-			return storage.ErrSeriesSet(err)
-		}
-
-		return seriesSet
+		return series.MetricsToSeriesSet(ctx, sortSeries, ms)
 	}
 
 	return q.streamingSelect(ctx, sortSeries, minT, maxT, matchers)

pkg/querier/series/series_set.go

@@ -168,18 +168,18 @@ func MatrixToSeriesSet(sortSeries bool, m model.Matrix) storage.SeriesSet {
 }
 
 // MetricsToSeriesSet creates a storage.SeriesSet from a []metric.Metric
-func MetricsToSeriesSet(ctx context.Context, sortSeries bool, ms []metric.Metric) (storage.SeriesSet, error) {
+func MetricsToSeriesSet(ctx context.Context, sortSeries bool, ms []metric.Metric) storage.SeriesSet {
 	series := make([]storage.Series, 0, len(ms))
 	for _, m := range ms {
 		if ctx.Err() != nil {
-			return nil, ctx.Err()
+			return storage.ErrSeriesSet(ctx.Err())
 		}
 		series = append(series, &ConcreteSeries{
 			labels:  metricToLabels(m.Metric),
 			samples: nil,
 		})
 	}
-	return NewConcreteSeriesSet(sortSeries, series), nil
+	return NewConcreteSeriesSet(sortSeries, series)
 }
 
 func metricToLabels(m model.Metric) labels.Labels {