diff --git a/integration/grpc_compression_test.go b/integration/grpc_compression_test.go index ac83158da0..0134c6aecf 100644 --- a/integration/grpc_compression_test.go +++ b/integration/grpc_compression_test.go @@ -43,7 +43,8 @@ func TestGRPCCompression(t *testing.T) { require.NoError(t, distributor.WaitSumMetricsWithOptions(e2e.Equals(1), []string{"cortex_ring_members"}, e2e.WithLabelMatchers( labels.MustNewMatcher(labels.MatchEqual, "name", "ingester"), - labels.MustNewMatcher(labels.MatchEqual, "state", "ACTIVE")))) + labels.MustNewMatcher(labels.MatchEqual, "state", "ACTIVE")), + e2e.WaitMissingMetrics)) c, err := e2ecortex.NewClient(distributor.HTTPEndpoint(), querier.HTTPEndpoint(), "", "", userID) require.NoError(t, err) @@ -95,7 +96,8 @@ func TestGRPCCompression(t *testing.T) { require.NoError(t, distributor.WaitSumMetricsWithOptions(e2e.Equals(1), []string{"cortex_ring_members"}, e2e.WithLabelMatchers( labels.MustNewMatcher(labels.MatchEqual, "name", "ingester"), - labels.MustNewMatcher(labels.MatchEqual, "state", "ACTIVE")))) + labels.MustNewMatcher(labels.MatchEqual, "state", "ACTIVE")), + e2e.WaitMissingMetrics)) c, err := e2ecortex.NewClient(distributor.HTTPEndpoint(), querier.HTTPEndpoint(), "", "", userID) require.NoError(t, err)