@@ -76,6 +76,11 @@ func (g *General) DesiredDeployment(s *suggestionsv1beta1.Suggestion) (*appsv1.D
76
76
if err != nil {
77
77
return nil , err
78
78
}
79
+ if containsContainerPortWithName (suggestionConfigData .Ports , consts .DefaultSuggestionPortName ) ||
80
+ containsContainerPort (suggestionConfigData .Ports , consts .DefaultSuggestionPort ) {
81
+ return nil , fmt .Errorf ("invalid suggestion config: a port with name %q or number %d must not be specified" ,
82
+ consts .DefaultSuggestionPortName , consts .DefaultSuggestionPort )
83
+ }
79
84
80
85
// If early stopping is used, get the config data.
81
86
earlyStoppingConfigData := katibconfig.EarlyStoppingConfig {}
@@ -195,14 +200,11 @@ func (g *General) desiredContainers(s *suggestionsv1beta1.Suggestion,
195
200
suggestionContainer .Name = consts .ContainerSuggestion
196
201
}
197
202
198
- if ! containsContainerPortWithName (suggestionContainer .Ports , consts .DefaultSuggestionPortName ) &&
199
- ! containsContainerPort (suggestionConfigData .Ports , consts .DefaultSuggestionPort ) {
200
- suggestionPort := corev1.ContainerPort {
201
- Name : consts .DefaultSuggestionPortName ,
202
- ContainerPort : consts .DefaultSuggestionPort ,
203
- }
204
- suggestionContainer .Ports = append (suggestionContainer .Ports , suggestionPort )
203
+ suggestionPort := corev1.ContainerPort {
204
+ Name : consts .DefaultSuggestionPortName ,
205
+ ContainerPort : consts .DefaultSuggestionPort ,
205
206
}
207
+ suggestionContainer .Ports = append (suggestionContainer .Ports , suggestionPort )
206
208
207
209
if viper .GetBool (consts .ConfigEnableGRPCProbeInSuggestion ) && suggestionContainer .ReadinessProbe == nil {
208
210
suggestionContainer .ReadinessProbe = & corev1.Probe {
0 commit comments