Add better timeout message

pkg/store/proxy.go

@@ -334,10 +334,10 @@ func startStreamSeriesSet(
 // Next blocks until new message is received or stream is closed or operation is timed out.
 func (s *streamSeriesSet) Next() (ok bool) {
 	ctx := s.ctx
-	timeoutMsg := ""
+	timeoutMsg := fmt.Sprintf("failed to receive any data from %s", s.name)
 
 	if s.responseTimeout != 0 {
-		timeoutMsg = s.responseTimeout.String()
+		timeoutMsg = fmt.Sprintf("failed to receive any data in %s from %s", s.responseTimeout.String(), s.name)
 
 		timeoutCtx, done := context.WithTimeout(s.ctx, s.responseTimeout)
 		defer done()
@@ -351,8 +351,7 @@ func (s *streamSeriesSet) Next() (ok bool) {
 		//shutdown a goroutine in startStreamSeriesSet
 		s.closeSeries()
 
-		err := errors.Wrapf(ctx.Err(), "failed to receive any data in %s from %s", timeoutMsg, s.name)
-
+		err := errors.Wrap(ctx.Err(), timeoutMsg)
 		if s.partialResponse {
 			level.Warn(s.logger).Log("err", err, "msg", "returning partial response")
 			s.warnCh.send(storepb.NewWarnSeriesResponse(err))