diff --git a/cmd/pytorch-operator.v1beta1/app/server.go b/cmd/pytorch-operator.v1beta1/app/server.go index 63187da47..421af567e 100644 --- a/cmd/pytorch-operator.v1beta1/app/server.go +++ b/cmd/pytorch-operator.v1beta1/app/server.go @@ -21,7 +21,6 @@ import ( log "github.com/sirupsen/logrus" "k8s.io/api/core/v1" - crdclient "k8s.io/apiextensions-apiserver/pkg/client/clientset/clientset" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" kubeinformers "k8s.io/client-go/informers" kubeclientset "k8s.io/client-go/kubernetes" @@ -156,14 +155,6 @@ func Run(opt *options.ServerOption) error { func createClientSets(config *restclientset.Config) (kubeclientset.Interface, kubeclientset.Interface, jobclientset.Interface, error) { - crdClient, err := crdclient.NewForConfig(config) - - if err != nil { - return nil, nil, nil, err - } - - checkCRDExists(crdClient, v1beta1.PytorchCRD) - kubeClientSet, err := kubeclientset.NewForConfig(restclientset.AddUserAgent(config, "pytorch-operator")) if err != nil { return nil, nil, nil, err @@ -181,12 +172,3 @@ func createClientSets(config *restclientset.Config) (kubeclientset.Interface, ku return kubeClientSet, leaderElectionClientSet, jobClientSet, nil } - -func checkCRDExists(clientset crdclient.Interface, crdName string) { - _, err := clientset.ApiextensionsV1beta1().CustomResourceDefinitions().Get(crdName, metav1.GetOptions{}) - - if err != nil { - log.Error(err) - os.Exit(1) - } -}