in api/jobset/v1alpha1/jobset_webhook.go [72:82]
func (js *JobSet) ValidateCreate() error {
var allErrs []error
// Validate that replicatedJobs listed in success policy are part of this JobSet.
validReplicatedJobs := replicatedJobNamesFromSpec(js)
for _, rjobName := range js.Spec.SuccessPolicy.TargetReplicatedJobs {
if !util.Contains(validReplicatedJobs, rjobName) {
allErrs = append(allErrs, fmt.Errorf("invalid replicatedJob name '%s' does not appear in .spec.ReplicatedJobs", rjobName))
}
}
return errors.Join(allErrs...)
}