From d5e4b59952483076e84f451cdd30c52b83829b61 Mon Sep 17 00:00:00 2001 From: Kevin Su Date: Thu, 31 Aug 2023 10:27:44 -0700 Subject: [PATCH] update config Signed-off-by: Kevin Su --- go/tasks/plugins/k8s/kfoperators/common/config.go | 2 +- go/tasks/plugins/k8s/kfoperators/mpi/mpi.go | 2 +- go/tasks/plugins/k8s/kfoperators/pytorch/pytorch.go | 2 +- go/tasks/plugins/k8s/kfoperators/tensorflow/tensorflow.go | 2 +- 4 files changed, 4 insertions(+), 4 deletions(-) diff --git a/go/tasks/plugins/k8s/kfoperators/common/config.go b/go/tasks/plugins/k8s/kfoperators/common/config.go index cac5cd304..7803e9097 100644 --- a/go/tasks/plugins/k8s/kfoperators/common/config.go +++ b/go/tasks/plugins/k8s/kfoperators/common/config.go @@ -14,7 +14,7 @@ var ( Timeout: config.Duration{Duration: 1 * time.Minute}, } - configSection = pluginsConfig.MustRegisterSubSection("common", &defaultConfig) + configSection = pluginsConfig.MustRegisterSubSection("kf-operator", &defaultConfig) ) // Config is config for 'pytorch' plugin diff --git a/go/tasks/plugins/k8s/kfoperators/mpi/mpi.go b/go/tasks/plugins/k8s/kfoperators/mpi/mpi.go index f792d9bc6..7b6974ef8 100644 --- a/go/tasks/plugins/k8s/kfoperators/mpi/mpi.go +++ b/go/tasks/plugins/k8s/kfoperators/mpi/mpi.go @@ -210,7 +210,7 @@ func (mpiOperatorResourceHandler) GetTaskPhase(_ context.Context, pluginContext return pluginsCore.PhaseInfoUndefined, err } if app.Status.StartTime == nil && app.CreationTimestamp.Add(common.GetConfig().Timeout.Duration).Before(time.Now()) { - return pluginsCore.PhaseInfoUndefined, fmt.Errorf("kubeflow operator hasn't updated the mpi coustum resource since creation time %v", app.CreationTimestamp) + return pluginsCore.PhaseInfoUndefined, fmt.Errorf("kubeflow operator hasn't updated the mpi custom resource since creation time %v", app.CreationTimestamp) } currentCondition, err := common.ExtractCurrentCondition(app.Status.Conditions) if err != nil { diff --git a/go/tasks/plugins/k8s/kfoperators/pytorch/pytorch.go b/go/tasks/plugins/k8s/kfoperators/pytorch/pytorch.go index f25712db6..d6f18b1a3 100644 --- a/go/tasks/plugins/k8s/kfoperators/pytorch/pytorch.go +++ b/go/tasks/plugins/k8s/kfoperators/pytorch/pytorch.go @@ -232,7 +232,7 @@ func (pytorchOperatorResourceHandler) GetTaskPhase(_ context.Context, pluginCont } if app.Status.StartTime == nil && app.CreationTimestamp.Add(common.GetConfig().Timeout.Duration).Before(time.Now()) { - return pluginsCore.PhaseInfoUndefined, fmt.Errorf("kubeflow operator hasn't updated the pytorch coustum resource since creation time %v", app.CreationTimestamp) + return pluginsCore.PhaseInfoUndefined, fmt.Errorf("kubeflow operator hasn't updated the pytorch custom resource since creation time %v", app.CreationTimestamp) } currentCondition, err := common.ExtractCurrentCondition(app.Status.Conditions) if err != nil { diff --git a/go/tasks/plugins/k8s/kfoperators/tensorflow/tensorflow.go b/go/tasks/plugins/k8s/kfoperators/tensorflow/tensorflow.go index 6e7a03145..fb006935b 100644 --- a/go/tasks/plugins/k8s/kfoperators/tensorflow/tensorflow.go +++ b/go/tasks/plugins/k8s/kfoperators/tensorflow/tensorflow.go @@ -210,7 +210,7 @@ func (tensorflowOperatorResourceHandler) GetTaskPhase(_ context.Context, pluginC } if app.Status.StartTime == nil && app.CreationTimestamp.Add(common.GetConfig().Timeout.Duration).Before(time.Now()) { - return pluginsCore.PhaseInfoUndefined, fmt.Errorf("kubeflow operator hasn't updated the tensorflow coustum resource since creation time %v", app.CreationTimestamp) + return pluginsCore.PhaseInfoUndefined, fmt.Errorf("kubeflow operator hasn't updated the tensorflow custom resource since creation time %v", app.CreationTimestamp) } currentCondition, err := common.ExtractCurrentCondition(app.Status.Conditions)