Skip to content

Commit ad6b4b1

Browse files
committed
add resources to earlystopping container
1 parent 0a1cb31 commit ad6b4b1

File tree

2 files changed

+7
-2
lines changed

2 files changed

+7
-2
lines changed

pkg/controller.v1beta1/suggestion/composer/composer.go

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -248,6 +248,7 @@ func (g *General) desiredContainers(s *suggestionsv1beta1.Suggestion,
248248
ContainerPort: consts.DefaultEarlyStoppingPort,
249249
},
250250
},
251+
Resources: earlyStoppingConfigData.Resource,
251252
}
252253

253254
containers = append(containers, earlyStoppingContainer)

pkg/util/v1beta1/katibconfig/config.go

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -46,8 +46,9 @@ type SuggestionConfig struct {
4646

4747
// EarlyStoppingConfig is the JSON early stopping structure in Katib config.
4848
type EarlyStoppingConfig struct {
49-
Image string `json:"image"`
50-
ImagePullPolicy corev1.PullPolicy `json:"imagePullPolicy,omitempty"`
49+
Image string `json:"image"`
50+
ImagePullPolicy corev1.PullPolicy `json:"imagePullPolicy,omitempty"`
51+
Resource corev1.ResourceRequirements `json:"resources,omitempty"`
5152
}
5253

5354
// MetricsCollectorConfig is the JSON metrics collector structure in Katib config.
@@ -177,6 +178,9 @@ func GetEarlyStoppingConfigData(algorithmName string, client client.Client) (Ear
177178
// Set Image Pull Policy.
178179
earlyStoppingConfigData.ImagePullPolicy = setImagePullPolicy(earlyStoppingConfigData.ImagePullPolicy)
179180

181+
// Set resource requirements
182+
earlyStoppingConfigData.Resource = setResourceRequirements(earlyStoppingConfigData.Resource)
183+
180184
return earlyStoppingConfigData, nil
181185
}
182186

0 commit comments

Comments
 (0)