fix wrong Pipeline in action allocate

Signed-off-by: Tizen Ye <yzs981130@126.com>
volcano-sh · Mar 15, 2021 · f84cdff · f84cdff
1 parent b09b8af
commit f84cdff
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pkg/scheduler/actions/allocate/allocate.go b/pkg/scheduler/actions/allocate/allocate.go
@@ -243,7 +243,7 @@ func (alloc *Action) 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 := ssn.Pipeline(task, node.Name); err != nil {
+					if err := stmt.Pipeline(task, node.Name); err != nil {
 						klog.Errorf("Failed to pipeline Task %v on %v in Session %v for %v.",
 							task.UID, node.Name, ssn.UID, err)
 					} else {