add events for pod with pipelined state

volcano-sh · Nov 3, 2019 · db0126c · db0126c
1 parent 20b0327
commit db0126c
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pkg/scheduler/cache/cache.go b/pkg/scheduler/cache/cache.go
@@ -851,7 +851,7 @@ func (sc *SchedulerCache) RecordJobStatusEvent(job *kbapi.JobInfo) {
 	}
 
 	// Update podCondition for tasks Allocated and Pending before job discarded
-	for _, status := range []api.TaskStatus{api.Allocated, api.Pending} {
+	for _, status := range []api.TaskStatus{api.Allocated, api.Pending, api.Pipelined} {
 		for _, taskInfo := range job.TaskStatusIndex[status] {
 			msg := baseErrorMessage
 			fitError := job.NodesFitErrors[taskInfo.UID]