fix podgroup event and condition messages inconsistent

Signed-off-by: rayoluo <[email protected]>
volcano-sh · Jun 25, 2023 · 2c0e901 · 2c0e901
1 parent ed5c215
commit 2c0e901
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/pkg/scheduler/plugins/gang/gang.go b/pkg/scheduler/plugins/gang/gang.go
@@ -25,6 +25,7 @@ import (
 
 	"volcano.sh/apis/pkg/apis/scheduling"
 	"volcano.sh/apis/pkg/apis/scheduling/v1beta1"
+
 	"volcano.sh/volcano/pkg/scheduler/api"
 	"volcano.sh/volcano/pkg/scheduler/framework"
 	"volcano.sh/volcano/pkg/scheduler/metrics"
@@ -178,7 +179,11 @@ func (gp *gangPlugin) OnSessionClose(ssn *framework.Session) {
 				}
 				return num + job.ReadyTaskNum()
 			}
-			unreadyTaskCount = job.MinAvailable - schedulableTaskNum()
+			if total := int32(len(job.Tasks)); job.MinAvailable > total {
+				unreadyTaskCount = total - schedulableTaskNum()
+			} else {
+				unreadyTaskCount = job.MinAvailable - schedulableTaskNum()
+			}
 			msg := fmt.Sprintf("%v/%v tasks in gang unschedulable: %v",
 				unreadyTaskCount, len(job.Tasks), job.FitError())
 			job.JobFitErrors = msg