Merge pull request #151 from abhinavdahiya/fix_max_workers_init

cvo: fix max_workers to number of nodes in graph
openshift · Apr 1, 2019 · b72cf63 · b72cf63
2 parents fc1c824 + 881d0eb
commit b72cf63
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/pkg/cvo/sync_worker.go b/pkg/cvo/sync_worker.go
@@ -463,9 +463,9 @@ func (w *SyncWorker) apply(ctx context.Context, payloadUpdate *payload.Update, w
 	graph := payload.NewTaskGraph(tasks)
 	graph.Split(payload.SplitOnJobs)
 	if work.State == payload.InitializingPayload {
-		// get the payload out via brute force
-		maxWorkers = len(tasks)
 		graph.Parallelize(payload.FlattenByNumberAndComponent)
+		// get the payload out via brute force
+		maxWorkers = len(graph.Nodes)
 	} else {
 		graph.Parallelize(payload.ByNumberAndComponent)
 	}