diff --git a/test/e2e/query_frontend_test.go b/test/e2e/query_frontend_test.go index a7d6c3511fc..2d94fc46b0e 100644 --- a/test/e2e/query_frontend_test.go +++ b/test/e2e/query_frontend_test.go @@ -81,8 +81,6 @@ func TestQueryFrontend(t *testing.T) { }, }) - RemoteWrite(seriest, q.InternalEndpoint("http")) - inMemoryCacheConfig := queryfrontend.CacheProviderConfig{ Type: queryfrontend.INMEMORY, Config: queryfrontend.InMemoryResponseCacheConfig{ @@ -98,6 +96,8 @@ func TestQueryFrontend(t *testing.T) { ctx, cancel := context.WithTimeout(context.Background(), time.Minute) t.Cleanup(cancel) + RemoteWrite(ctx, seriest, q.InternalEndpoint("http")) + testutil.Ok(t, q.WaitSumMetricsWithOptions(e2emon.Equals(1), []string{"thanos_store_nodes_grpc_connections"}, e2emon.WaitMissingMetrics())) // Ensure we can get the result from Querier first so that it