Skip to content
Closed
Changes from all commits
Commits
File filter

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
temp fix for nil preemptIDs by qm lib
  • Loading branch information
asm582 committed Jul 18, 2023
commit b4c1ef6293b4b862b344f4619b2737341a063039
Original file line number Diff line number Diff line change
Expand Up @@ -568,7 +568,13 @@ func (qm *QuotaManager) Fits(aw *arbv1.AppWrapper, awResDemands *clusterstateapi
qm.removeConsumer(consumerID)
return doesFit, preemptIds, strings.TrimSpace(allocResponse.GetMessage())
}
preemptIds = qm.getAppWrappers(allocResponse.GetPreemptedIds())
if len(allocResponse.GetPreemptedIds()) > 0 {
preemptIds = qm.getAppWrappers(allocResponse.GetPreemptedIds())
} else {
var s []string
s = append(s, allocResponse.GetConsumerID())
preemptIds = qm.getAppWrappers(s)
}
return doesFit, preemptIds, strings.TrimSpace(allocResponse.GetMessage())
}

Expand Down