@@ -539,7 +539,7 @@ func (meal *cfgMeal) digestNewPLsLocked(newPLs []*flowcontrol.PriorityLevelConfi
539
539
state := meal .cfgCtlr .priorityLevelStates [pl .Name ]
540
540
if state == nil {
541
541
labelValues := []string {pl .Name }
542
- state = & priorityLevelState {reqsObsPair : meal .cfgCtlr .reqsObsPairGenerator .Generate (1 , 1 , labelValues ), execSeatsObs : meal .cfgCtlr .execSeatsObsGenerator .Generate (1 , 1 , labelValues )}
542
+ state = & priorityLevelState {reqsObsPair : meal .cfgCtlr .reqsObsPairGenerator .Generate (1 , 1 , labelValues ), execSeatsObs : meal .cfgCtlr .execSeatsObsGenerator .Generate (0 , 1 , labelValues )}
543
543
}
544
544
qsCompleter , err := queueSetCompleterForPL (meal .cfgCtlr .queueSetFactory , state .queues , pl , meal .cfgCtlr .requestWaitLimit , state .reqsObsPair , state .execSeatsObs )
545
545
if err != nil {
@@ -769,7 +769,7 @@ func (meal *cfgMeal) imaginePL(proto *flowcontrol.PriorityLevelConfiguration, re
769
769
klog .V (3 ).Infof ("No %s PriorityLevelConfiguration found, imagining one" , proto .Name )
770
770
labelValues := []string {proto .Name }
771
771
reqsObsPair := meal .cfgCtlr .reqsObsPairGenerator .Generate (1 , 1 , labelValues )
772
- execSeatsObs := meal .cfgCtlr .execSeatsObsGenerator .Generate (1 , 1 , labelValues )
772
+ execSeatsObs := meal .cfgCtlr .execSeatsObsGenerator .Generate (0 , 1 , labelValues )
773
773
qsCompleter , err := queueSetCompleterForPL (meal .cfgCtlr .queueSetFactory , nil , proto , requestWaitLimit , reqsObsPair , execSeatsObs )
774
774
if err != nil {
775
775
// This can not happen because proto is one of the mandatory
0 commit comments