diff --git a/pkg/apis/config/kubeclient.go b/pkg/apis/config/kubeclient.go index 32c290c35..01e6d8101 100644 --- a/pkg/apis/config/kubeclient.go +++ b/pkg/apis/config/kubeclient.go @@ -41,6 +41,8 @@ func initKubeClient(kubeconfig string) (clientcmd.ClientConfig, *rest.Config, *k if err != nil { return nil, nil, nil, err } + restConfig.QPS = 10 + restConfig.Burst = 20 // create the clientset clientset, err := kubernetes.NewForConfig(restConfig) if err != nil { diff --git a/pkg/workflow/workflow.go b/pkg/workflow/workflow.go index 9091cf470..0c61ad6a7 100644 --- a/pkg/workflow/workflow.go +++ b/pkg/workflow/workflow.go @@ -171,8 +171,7 @@ func SubmitJob(name string, trainingType string, namespace string, values interf trainingType == string(types.PytorchTrainingJob) { err := kubectl.PatchOwnerReferenceWithAppInfoFile(name, trainingType, appInfoFileName, namespace) if err != nil { - log.Warnf("Failed to patch ownerReference %s due to %v`", name, err) - return err + log.Debugf("Failed to patch ownerReference %s due to %v`", name, err) } }