Merge pull request #506 from sivanzcw/bugfix

Add events for pod with pipelined state
volcano-sh · Nov 4, 2019 · 12aa7a0 · 12aa7a0
2 parents 5f271fa + db0126c
commit 12aa7a0
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]