fix integration test

Signed-off-by: Ben Ye <[email protected]>

Author: yeya24

integration/e2ecortex/client.go

@@ -167,6 +167,9 @@ func (c *Client) RemoteRead(matchers []*labels.Matcher, start, end time.Time, st
 		Start: startMs,
 		End:   endMs,
 	})
+	if err != nil {
+		return nil, err
+	}
 
 	req := &prompb.ReadRequest{
 		Queries:               []*prompb.Query{q},
@@ -184,6 +187,9 @@ func (c *Client) RemoteRead(matchers []*labels.Matcher, start, end time.Time, st
 	defer cancel()
 
 	httpReq, err := http.NewRequestWithContext(httpReqCtx, "POST", "http://"+c.querierAddress+"/prometheus/api/v1/read", bytes.NewReader(compressed))
+	if err != nil {
+		return nil, err
+	}
 	httpReq.Header.Set("X-Scope-OrgID", "user-1")
 	httpReq.Header.Add("Content-Encoding", "snappy")
 	httpReq.Header.Add("Accept-Encoding", "snappy")

integration/query_frontend_test.go

@@ -323,9 +323,9 @@ func runQueryFrontendTest(t *testing.T, cfg queryFrontendTestConfig) {
 
 		// No need to repeat the test on remote read for each user.
 		if userID == 0 && cfg.remoteReadEnabled {
-			start := time.Unix(1595846748, 806*1e6)
-			end := time.Unix(1595846750, 806*1e6)
-			res, err := c.RemoteRead([]*labels.Matcher{labels.MustNewMatcher(labels.MatchEqual, "__name__", "series_1")}, start, end, time.Second)
+			start := now.Add(-1 * time.Hour)
+			end := now.Add(1 * time.Hour)
+			res, err := c.RemoteRead([]*labels.Matcher{labels.MustNewMatcher(labels.MatchEqual, labels.MetricName, "series_1")}, start, end, time.Second)
 			require.NoError(t, err)
 			require.True(t, len(res.Results) > 0)
 			require.True(t, len(res.Results[0].Timeseries) > 0)