diff --git a/cluster-autoscaler/cloudprovider/gce/mig_info_provider.go b/cluster-autoscaler/cloudprovider/gce/mig_info_provider.go index d2931753e007..815b78e532ed 100644 --- 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...)