Skip to content

Commit

Permalink
pipeline task if task's request resource less than the releasing reso…
Browse files Browse the repository at this point in the history
…urce of node during performing allocate action
  • Loading branch information
sivanzcw committed Dec 16, 2019
1 parent 33fa0fd commit ca0f2dd
Showing 1 changed file with 3 additions and 3 deletions.
6 changes: 3 additions & 3 deletions pkg/scheduler/actions/allocate/allocate.go
Original file line number Diff line number Diff line change
Expand Up @@ -216,9 +216,9 @@ func (alloc *allocateAction) Execute(ssn *framework.Session) {
if task.InitResreq.LessEqual(node.FutureIdle()) {
klog.V(3).Infof("Pipelining Task <%v/%v> to node <%v> for <%v> on <%v>",
task.Namespace, task.Name, node.Name, task.InitResreq, node.Releasing)
if err := stmt.Pipeline(task, node.Name); err != nil {
klog.Errorf("Failed to pipeline Task %v on %v",
task.UID, node.Name)
if err := ssn.Pipeline(task, node.Name); err != nil {
klog.Errorf("Failed to pipeline Task %v on %v in Session %v.",
task.UID, node.Name, ssn.UID)
}
}
}
Expand Down

0 comments on commit ca0f2dd

Please sign in to comment.