-
Notifications
You must be signed in to change notification settings - Fork 953
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
Pod Scheduling Readiness Draft #3612
Conversation
Signed-off-by: ykcai-daniel <1155141377@link.cuhk.edu.hk>
[APPROVALNOTIFIER] This PR is NOT APPROVED This pull-request has been approved by: The full list of commands accepted by this bot can be found here.
Needs approval from an approver in each of these files:
Approvers can indicate their approval by writing |
@@ -171,4 +171,5 @@ replace ( | |||
k8s.io/sample-apiserver => k8s.io/sample-apiserver v0.30.2 | |||
k8s.io/sample-cli-plugin => k8s.io/sample-cli-plugin v0.30.2 | |||
k8s.io/sample-controller => k8s.io/sample-controller v0.30.2 | |||
volcano.sh/apis => github.com/ykcai-daniel/apis v0.1.0 |
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.
Is this replacement necessary?
@@ -339,6 +339,7 @@ type JobInfo struct { | |||
// * value means workload can use all the revocable node for during node active revocable time. | |||
RevocableZone string | |||
Budget *DisruptionBudget | |||
|
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.
nit: not necessary
func (ji* JobInfo) SchedulingGated() bool{ | ||
for _,task:= range ji.Tasks{ | ||
if len(task.Pod.Spec.SchedulingGates) > 0 { | ||
ji.PodGroup.Status.Phase=scheduling.PodGroupSchGated |
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.
Please adjust the indentation of the code. The same as above for other places
slot1 := corev1.ResourceList{ | ||
corev1.ResourceCPU: resource.MustParse("1000m"), | ||
corev1.ResourceMemory: resource.MustParse("1024Mi")} | ||
// slot2 := corev1.ResourceList{ |
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.
nit: not necessary
Add new state PodGroupSchGated and modified scheduler actions. More details in #3581