update config

Signed-off-by: Kevin Su <[email protected]>
flyteorg · Aug 31, 2023 · d5e4b59 · d5e4b59
1 parent 0a0e00d
commit d5e4b59
Show file tree

Hide file tree

Showing 4 changed files with 4 additions and 4 deletions.
diff --git 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
@@ -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
@@ -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
@@ -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)