github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2026-07-18 13:57:38 +00:00
Code Issues Projects Releases Wiki Activity

scheduler: Added isOpportunisticBatchingEnabled in scheduling_queue.go

Browse Source
This commit is contained in:
Roman Baron
2026-03-08 15:00:02 +02:00
parent 623d42b8bf
commit 2a394caa07
1 changed files with 5 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
pkg/scheduler/backend/queue/scheduling_queue.go
View File

@@ -220,6 +220,8 @@ type PriorityQueue struct {
isPopFromBackoffQEnabled bool
// isGenericWorkloadEnabled indicates whether the feature gate GenericWorkload is enabled.
isGenericWorkloadEnabled bool
// isOpportunisticBatchingEnabled indicates whether the OpportunisticBatching feature gate is enabled.
isOpportunisticBatchingEnabled bool
}
// QueueingHintFunction is the wrapper of QueueingHintFn that has PluginName.
@@ -377,6 +379,7 @@ func NewPriorityQueue(
isSchedulingQueueHintEnabled := utilfeature.DefaultFeatureGate.Enabled(features.SchedulerQueueingHints)
isPopFromBackoffQEnabled := utilfeature.DefaultFeatureGate.Enabled(features.SchedulerPopFromBackoffQ)
isGenericWorkloadEnabled := utilfeature.DefaultFeatureGate.Enabled(features.GenericWorkload)
isOpportunisticBatchingEnabled := utilfeature.DefaultFeatureGate.Enabled(features.OpportunisticBatching)
lessConverted := convertLessFn(lessFn)
backoffQ := newBackoffQueue(options.clock, options.podInitialBackoffDuration, options.podMaxBackoffDuration, lessFn, isPopFromBackoffQEnabled)
@@ -397,6 +400,7 @@ func NewPriorityQueue(
isSchedulingQueueHintEnabled: isSchedulingQueueHintEnabled,
isPopFromBackoffQEnabled: isPopFromBackoffQEnabled,
isGenericWorkloadEnabled: isGenericWorkloadEnabled,
isOpportunisticBatchingEnabled: isOpportunisticBatchingEnabled,
}
var backoffQPopper backoffQPopper
if isPopFromBackoffQEnabled {
@@ -1512,7 +1516,7 @@ func (p *PriorityQueue) NominatedPodsForNode(nodeName string) []fwk.PodInfo {
// signPod computes the scheduling signature for the given pod when OpportunisticBatching is enabled.
// The signature is used to cache and reuse scheduling results for identical pods.
func (p *PriorityQueue) signPod(ctx context.Context, logger klog.Logger, pod *v1.Pod) fwk.PodSignature {
if !utilfeature.DefaultFeatureGate.Enabled(features.OpportunisticBatching) {
if !p.isOpportunisticBatchingEnabled {
return nil
}