Update podgroup.go

GonzaloSaez · web-flow · commit 1a2e91b6785d · 2024-10-29T19:10:37.000+01:00
Signed-off-by: GonzaloSaez &lt;11050889+GonzaloSaez@users.noreply.github.com&gt;
diff --git a/pkg/controller/podgroup.go b/pkg/controller/podgroup.go
@@ -361,7 +361,7 @@ func calPGMinResource(minMember *int32, mpiJob *kubeflow.MPIJob, pcLister schedu
 		// When using runLauncherAsWorker, there may be no worker.
 		replicas += *order[1].Replicas
 	}
-	if minMember != nil && *order[0].Replicas+*order[1].Replicas > *minMember {
+	if minMember != nil && replicas > *minMember {
 		// If the launcher and workers have the same priority, it treats workers as a lower priority.
 		if order[0].priority == order[1].priority {
 			wIndex := order.getWorkerIndex()

Original file line number	Diff line number	Diff line change
`@@ -361,7 +361,7 @@ func calPGMinResource(minMember int32, mpiJob kubeflow.MPIJob, pcLister schedu`
`361`	`361`	`// When using runLauncherAsWorker, there may be no worker.`
`362`	`362`	`replicas += *order[1].Replicas`
`363`	`363`	`}`
`364`		`- if minMember != nil && order[0].Replicas+order[1].Replicas > *minMember {`
	`364`	`+ if minMember != nil && replicas > *minMember {`
`365`	`365`	`// If the launcher and workers have the same priority, it treats workers as a lower priority.`
`366`	`366`	`if order[0].priority == order[1].priority {`
`367`	`367`	`wIndex := order.getWorkerIndex()`