Skip to content

Commit 6a46db2

Browse files
committed
valid task name
1 parent 12e24b1 commit 6a46db2

File tree

1 file changed

+7
-0
lines changed

1 file changed

+7
-0
lines changed

pkg/admission/admit_job.go

+7
Original file line numberDiff line numberDiff line change
@@ -26,12 +26,14 @@ import (
2626

2727
"k8s.io/api/admission/v1beta1"
2828
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
29+
"k8s.io/apimachinery/pkg/util/validation"
2930

3031
v1alpha1 "volcano.sh/volcano/pkg/apis/batch/v1alpha1"
3132
)
3233

3334
// job admit.
3435
func AdmitJobs(ar v1beta1.AdmissionReview) *v1beta1.AdmissionResponse {
36+
3537
glog.V(3).Infof("admitting jobs -- %s", ar.Request.Operation)
3638

3739
job, err := DecodeJob(ar.Request.Object, ar.Request.Resource)
@@ -83,6 +85,11 @@ func validateJobSpec(jobSpec v1alpha1.JobSpec, reviewResponse *v1beta1.Admission
8385
// count replicas
8486
totalReplicas = totalReplicas + task.Replicas
8587

88+
// validate task name
89+
if errMsgs := validation.IsDNS1123Label(task.Name); len(errMsgs) > 0 {
90+
msg = msg + fmt.Sprintf(" %v;", errMsgs)
91+
}
92+
8693
// duplicate task name
8794
if _, found := taskNames[task.Name]; found {
8895
msg = msg + fmt.Sprintf(" duplicated task name %s;", task.Name)

0 commit comments

Comments
 (0)