The pipeline pod fails to be scheduled in the current scheduling peri…

…od. It is more reasonable to set reason to Unschedulable and compatible with autoscaler capacity expansion

Signed-off-by: w00568049 <[email protected]>

pkg/scheduler/api/job_info.go

@@ -653,13 +653,13 @@ func (ji *JobInfo) TaskSchedulingReason(tid TaskID) (reason string, msg string)
 
  msg = ji.JobFitErrors
  switch status := ctx.Status; status {
- case Allocated, Pipelined:
+ case Allocated:
  // Pod is schedulable
  msg = fmt.Sprintf("Pod %s/%s can possibly be assigned to %s", taskInfo.Namespace, taskInfo.Name, ctx.NodeName)
- if status == Pipelined {
- msg += " once resource is released"
- }
  return PodReasonSchedulable, msg
+ case Pipelined:
+ msg = fmt.Sprintf("Pod %s/%s can possibly be assigned to %s, once resource is released", taskInfo.Namespace, taskInfo.Name, ctx.NodeName)
+ return PodReasonUnschedulable, msg
  case Pending:
  if fe := ji.NodesFitErrors[tid]; fe != nil {
  // Pod is not schedulable