fix: only validate Kubernetes Job

pkg/webhook/v1beta1/experiment/validator/validator.go

@@ -376,26 +376,22 @@ func (g *DefaultValidator) validateTrialTemplate(instance *experimentsv1beta1.Ex
 func (g *DefaultValidator) validateTrialJob(runSpec *unstructured.Unstructured) error {
 	gvk := runSpec.GroupVersionKind()
 
-	// Validate only Job
-	switch gvk.Kind {
-	case consts.JobKindJob:
-		batchJob := batchv1.Job{}
-
-		// Validate that RunSpec can be converted to Batch Job
-		err := runtime.DefaultUnstructuredConverter.FromUnstructured(runSpec.Object, &batchJob)
-		if err != nil {
-			return fmt.Errorf("unable to convert spec.TrialTemplate: %v to %v: %v", runSpec.Object, gvk.Kind, err)
-		}
+	// Validate only Kubernetes Job
+	if gvk.GroupVersion() != batchv1.SchemeGroupVersion || gvk.Kind != consts.JobKindJob {
+		return nil
+	}
 
-		// Try to patch runSpec to Batch Job
-		// TODO (andreyvelich): Do we want to remove it completely ?
-		err = validatePatchJob(runSpec, batchJob, gvk.Kind)
-		if err != nil {
-			return err
-		}
+	batchJob := batchv1.Job{}
+
+	// Validate that RunSpec can be converted to Batch Job
+	err := runtime.DefaultUnstructuredConverter.FromUnstructured(runSpec.Object, &batchJob)
+	if err != nil {
+		return fmt.Errorf("unable to convert spec.TrialTemplate: %v to %v: %v", runSpec.Object, gvk.Kind, err)
 	}
 
-	return nil
+	// Try to patch runSpec to Batch Job
+	// TODO (andreyvelich): Do we want to remove it completely ?
+	return validatePatchJob(runSpec, batchJob, gvk.Kind)
 }
 
 func validatePatchJob(runSpec *unstructured.Unstructured, job interface{}, jobType string) error {

pkg/webhook/v1beta1/experiment/validator/validator_test.go

@@ -809,6 +809,19 @@ spec:
 		t.Errorf("ConvertStringToUnstructured failed: %v", err)
 	}
 
+	notKubernetesBatchJob := `apiVersion: test/v1
+kind: Job
+spec:
+  template:
+    spec:
+      containers:
+      - name: container`
+
+	notKubernetesBatchJobUnstr, err := util.ConvertStringToUnstructured(notKubernetesBatchJob)
+	if err != nil {
+		t.Errorf("ConvertStringToUnstructured failed: %v", err)
+	}
+
 	tcs := []struct {
 		RunSpec         *unstructured.Unstructured
 		Err             bool
@@ -835,6 +848,12 @@ spec:
 			Err:             false,
 			testDescription: "Valid case with nvidia.com/gpu resource in Trial template",
 		},
+		// Not kubernetes batch job
+		{
+			RunSpec:         notKubernetesBatchJobUnstr,
+			Err:             false,
+			testDescription: "Only validate Kuernetes Job",
+		},
 	}
 
 	for _, tc := range tcs {