fix(async search): return agg interval in req (#293)

Author: forshev

proxy/search/async.go

@@ -479,6 +479,7 @@ func buildRequestAggs(in []*storeapi.AggQuery) []AggQuery {
 			GroupBy:   agg.GroupBy,
 			Func:      agg.Func.MustAggFunc(),
 			Quantiles: agg.Quantiles,
+			Interval:  seq.MID(agg.Interval),
 		})
 	}
 	return reqAggs

proxyapi/grpc_async_search.go

@@ -181,12 +181,17 @@ func (g *grpcV1) DeleteAsyncSearch(
 
 func makeProtoRequestAggregations(sourceAggs []search.AggQuery) []*seqproxyapi.AggQuery {
 	aggs := make([]*seqproxyapi.AggQuery, 0, len(sourceAggs))
-	for _, agg := range sourceAggs {
+	for _, a := range sourceAggs {
 		agg := &seqproxyapi.AggQuery{
-			Field:     agg.Field,
-			GroupBy:   agg.GroupBy,
-			Func:      seqproxyapi.AggFunc(agg.Func),
-			Quantiles: agg.Quantiles,
+			Field:     a.Field,
+			GroupBy:   a.GroupBy,
+			Func:      seqproxyapi.AggFunc(a.Func),
+			Quantiles: a.Quantiles,
+		}
+
+		if a.Interval != 0 {
+			interval := seq.MIDToDuration(a.Interval).String()
+			agg.Interval = &interval
 		}
 
 		// Support legacy format in which field means groupBy.

storeapi/grpc_async_search.go

@@ -149,6 +149,9 @@ func convertAggQueriesToProto(query []processor.AggQuery) []*storeapi.AggQuery {
 		if q.GroupBy != nil {
 			pq.GroupBy = q.GroupBy.Field
 		}
+		if q.Interval != 0 {
+			pq.Interval = q.Interval
+		}
 		res = append(res, pq)
 	}
 	return res