enhancement: don't need to re-calculate job's allocated resource

Signed-off-by: lowang-bh <[email protected]>
volcano-sh · Aug 17, 2023 · 7a0c6c0 · 7a0c6c0
1 parent 890d8a1
commit 7a0c6c0
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 4 deletions.
diff --git a/pkg/scheduler/plugins/overcommit/overcommit.go b/pkg/scheduler/plugins/overcommit/overcommit.go
@@ -101,8 +101,7 @@ func (op *overcommitPlugin) OnSessionOpen(ssn *framework.Session) {
 		if job.PodGroup.Status.Phase == scheduling.PodGroupRunning &&
 			job.PodGroup.Spec.MinResources != nil &&
 			int32(util.CalculateAllocatedTaskNum(job)) >= job.PodGroup.Spec.MinMember {
-			allocated := util.GetAllocatedResource(job)
-			inqueued := util.GetInqueueResource(job, allocated)
+			inqueued := util.GetInqueueResource(job, job.Allocated)
 			op.inqueueResource.Add(inqueued)
 		}
 	}

diff --git a/pkg/scheduler/plugins/proportion/proportion.go b/pkg/scheduler/plugins/proportion/proportion.go
@@ -151,8 +151,7 @@ func (pp *proportionPlugin) OnSessionOpen(ssn *framework.Session) {
 		if job.PodGroup.Status.Phase == scheduling.PodGroupRunning &&
 			job.PodGroup.Spec.MinResources != nil &&
 			int32(util.CalculateAllocatedTaskNum(job)) >= job.PodGroup.Spec.MinMember {
-			allocated := util.GetAllocatedResource(job)
-			inqueued := util.GetInqueueResource(job, allocated)
+			inqueued := util.GetInqueueResource(job, job.Allocated)
 			attr.inqueue.Add(inqueued)
 		}
 		attr.elastic.Add(job.GetElasticResources())