Merge pull request #480 from k82cn/add_pipelined_pods

Added Pipelined Pods as valid tasks.
kubernetes-retired · Nov 24, 2018 · f5d5996 · f5d5996
2 parents 291729e + b2fac4e
commit f5d5996
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/pkg/scheduler/plugins/gang/gang.go b/pkg/scheduler/plugins/gang/gang.go
@@ -35,6 +35,7 @@ func New(args *framework.PluginArgs) framework.Plugin {
 	}
 }
 
+// readyTaskNum return the number of tasks that are ready to run.
 func readyTaskNum(job *api.JobInfo) int32 {
 	occupid := 0
 	for status, tasks := range job.TaskStatusIndex {
@@ -46,11 +47,13 @@ func readyTaskNum(job *api.JobInfo) int32 {
 	return int32(occupid)
 }
 
+// validTaskNum return the number of tasks that are valid.
 func validTaskNum(job *api.JobInfo) int32 {
 	occupid := 0
 	for status, tasks := range job.TaskStatusIndex {
 		if api.AllocatedStatus(status) ||
 			status == api.Succeeded ||
+			status == api.Pipelined ||
 			status == api.Pending {
 			occupid = occupid + len(tasks)
 		}