Merge pull request #7279 from damikag/refactor-mig-fetch-3

Parallelly fetch mig instances in differet zones when is enabled
kubernetes · Sep 13, 2024 · 6826dc5 · 6826dc5
2 parents d22b678 + 3001b6e
commit 6826dc5
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/cluster-autoscaler/cloudprovider/gce/mig_info_provider.go b/cluster-autoscaler/cloudprovider/gce/mig_info_provider.go
@@ -199,9 +199,9 @@ func (c *cachingMigInfoProvider) listInstancesInAllZonesWithMigs() ([]GceInstanc
 	zoneInstances := make([][]GceInstance, len(zones))
 	defer metrics.UpdateDurationFromStart(metrics.BulkListAllGceInstances, time.Now())
 
-	workqueue.ParallelizeUntil(context.Background(), c.concurrentGceRefreshes, len(zones), func(piece int) {
+	workqueue.ParallelizeUntil(context.Background(), len(zones), len(zones), func(piece int) {
 		zoneInstances[piece], errors[piece] = c.gceClient.FetchAllInstances(c.projectId, zones[piece], "")
-	}, workqueue.WithChunkSize(c.concurrentGceRefreshes))
+	})
 
 	for _, instances := range zoneInstances {
 		allInstances = append(allInstances, instances...)