Skip to content

fix double counting when AWs dont have any pods running #415

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.

Sign up for GitHub

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

Merged
merged 14 commits into from
Jun 28, 2023
Merged

fix double counting when AWs dont have any pods running #415

Changes from 1 commit
Commits
Show all changes
14 commits
Select commit Hold shift + click to select a range
714374e
fix double counting when AWs dont have any pods running
asm582 Jun 16, 2023
c81e05b
use proposed preemptions to dispatch
asm582 Jun 19, 2023
ff6c59a
perform histrogram checks prior to preemption or pending res eval
asm582 Jun 20, 2023
6f351aa
remove histograms
asm582 Jun 21, 2023
afe6397
negate nodechecks histogram
asm582 Jun 21, 2023
2017cfc
fix double counting for pending AWs
asm582 Jun 23, 2023
66a21c2
remove noisy logging
asm582 Jun 25, 2023
09c3852
print optimistic dispatch msg when preempt res acquired
asm582 Jun 25, 2023
0040e4c
release quota on completed AWs only when QM is enabled
asm582 Jun 25, 2023
adbe374
update CRDs
asm582 Jun 26, 2023
abbfe88
add all AW resources for status dispatched
asm582 Jun 27, 2023
93bb22a
add label to test dep
asm582 Jun 27, 2023
557f378
rollback test case change
asm582 Jun 27, 2023
d1c2352
reserve all res during dispatch
asm582 Jun 27, 2023
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
5 changes: 4 additions & 1 deletion pkg/controller/queuejob/queuejob_controller_ex.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -921,7 +921,10 @@ func (qjm *XController) getAggregatedAvailableResourcesPriority(unallocatedClust
}
for _, genericItem := range value.Spec.AggrResources.GenericItems {
qjv, _ := genericresource.GetResources(&genericItem)
preemptable = preemptable.Add(qjv)
//only add resources when AWs are truly running
if value.Status.State == arbv1.AppWrapperStateActive && value.Status.QueueJobState == arbv1.AppWrapperConditionType(arbv1.AppWrapperStateActive) {
preemptable = preemptable.Add(qjv)
}
}

continue
Expand Down