-
Notifications
You must be signed in to change notification settings - Fork 9
Conversation
|
||
pgResource := api.NewResource(*job.PodGroup.Spec.MinResources) | ||
// The queue resource quota limit has not reached | ||
if pgResource.Clone().Add(ssn.Queues[queue.UID].Allocated).LessEqual(api.NewResource(queue.Queue.Spec.Capability)) { |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
we should add an Enqueue
callback to ask plugin whehter it's ready to enqueue, refer to JobReady callback.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Will have a look
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
done
queue := ssn.Queues[queueID] | ||
pgResource := api.NewResource(*job.PodGroup.Spec.MinResources) | ||
// The queue resource quota limit has not reached | ||
if pgResource.Clone().Add(attr.allocated).LessEqual(api.NewResource(queue.Queue.Spec.Capability)) { |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
We may also consider maxPodGroup number as one of resource, we can open another PR for it.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
ok
LGTM overall, please ping me when CI is happy with that. |
Added Pod events.
/lgtm |
/lgtm |
/lgtm |
Implement queue Capability
Implement queue Capability
Implement queue Capability
What this PR does / why we need it:
Which issue(s) this PR fixes (optional, in
fixes #<issue number>(, fixes #<issue_number>, ...)
format, will close the issue(s) when PR gets merged):Partially fix volcano-sh/volcano#117
Special notes for your reviewer:
Release note: