Fixed integration test

pracucci · pracucci · commit fdbde79abc8c · 2020-11-02T10:24:06.000+01:00
Signed-off-by: Marco Pracucci &lt;marco@pracucci.com&gt;
diff --git a/integration/querier_sharding_test.go b/integration/querier_sharding_test.go
@@ -135,7 +135,7 @@ func runQuerierShardingTest(t *testing.T, cfg querierShardingTestConfig) {
 
 	// Wait until both workers connect to the query-frontend or query-scheduler
 	if cfg.querySchedulerEnabled {
-		require.NoError(t, queryScheduler.WaitSumMetrics(e2e.Equals(2), "cortex_query_scheduler_connected_frontend_clients"))
+		require.NoError(t, queryScheduler.WaitSumMetrics(e2e.Equals(2), "cortex_query_scheduler_connected_querier_clients"))
 	} else {
 		require.NoError(t, queryFrontend.WaitSumMetrics(e2e.Equals(2), "cortex_query_frontend_connected_clients"))
 	}

Original file line number	Diff line number	Diff line change
`@@ -135,7 +135,7 @@ func runQuerierShardingTest(t *testing.T, cfg querierShardingTestConfig) {`
`135`	`135`
`136`	`136`	`// Wait until both workers connect to the query-frontend or query-scheduler`
`137`	`137`	`if cfg.querySchedulerEnabled {`
`138`		`- require.NoError(t, queryScheduler.WaitSumMetrics(e2e.Equals(2), "cortex_query_scheduler_connected_frontend_clients"))`
	`138`	`+ require.NoError(t, queryScheduler.WaitSumMetrics(e2e.Equals(2), "cortex_query_scheduler_connected_querier_clients"))`
`139`	`139`	`} else {`
`140`	`140`	`require.NoError(t, queryFrontend.WaitSumMetrics(e2e.Equals(2), "cortex_query_frontend_connected_clients"))`
`141`	`141`	`}`