-
Notifications
You must be signed in to change notification settings - Fork 300
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Preemption within ClusterQueue and cohort #514
Conversation
[APPROVALNOTIFIER] This PR is APPROVED This pull-request has been approved by: alculquicondor The full list of commands accepted by this bot can be found here. The pull request process is described here
Needs approval from an approver in each of these files:
Approvers can indicate their approval by writing |
59bba33
to
7c68bdc
Compare
/assign @ahg-g |
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.
The suggestions for optimizations can be done on followup PRs.
"sigs.k8s.io/kueue/pkg/workload" | ||
) | ||
|
||
const parallelPreemptions = 8 |
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.
Do you have reasons why this is hardcoded?
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.
Just simplicity. We can add a configuration option later. But it might just be a general parallelism parameter, like in scheduler.
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.
Sounds good.
0283b1c
to
3aa7054
Compare
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.
/lgtm
/hold
for one nit
@@ -38,13 +38,16 @@ const ( | |||
isNegativeErrorMsg string = `must be greater than or equal to 0` | |||
) | |||
|
|||
type ClusterQueueWebhook struct{} | |||
type ClusterQueueWebhook struct { | |||
scheme *runtime.Scheme |
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.
where is this used?
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.
Left over from another approach I tried. Removed
1c0f8c6
to
d1384be
Compare
squashed into 2 commits |
/hold cancel |
With validation and defaulting Change-Id: Ifb618c6e0c0bbf7c8b721b30a764c5a62a8bde22
With integration tests
d1384be
to
ba9dcdf
Compare
/lgtm |
What type of PR is this?
/kind feature
/kind api-change
What this PR does / why we need it:
Implements https://github.com/kubernetes-sigs/kueue/tree/05da320/keps/83-workload-preemption
Which issue(s) this PR fixes:
Fixes #83
Special notes for your reviewer: