Fix config

flyteorg · Sep 29, 2020 · e54c081 · e54c081
1 parent 0b5580a
commit e54c081
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 2 deletions.
diff --git a/go/tasks/plugins/array/k8s/config.go b/go/tasks/plugins/array/k8s/config.go
@@ -106,7 +106,7 @@ func GetK8sClient(config ClusterConfig) (client.Client, error) {
 // Defines custom config for K8s Array plugin
 type Config struct {
 	DefaultScheduler     string            `json:"scheduler" pflag:",Decides the scheduler to use when launching array-pods."`
-	MaxErrorStringLength int               `json:"maxErrLength" pflag:",Determines the maximum length of the error string returned for the array."`
+	MaxErrorStringLength int               `json:"maxErrorLength" pflag:",Determines the maximum length of the error string returned for the array."`
 	MaxArrayJobSize      int64             `json:"maxArrayJobSize" pflag:",Maximum size of array job."`
 	ResourceConfig       ResourceConfig    `json:"resourceConfig" pflag:"-,ResourceConfiguration to limit number of resources used by k8s-array."`
 	RemoteClusterConfig  ClusterConfig     `json:"remoteClusterConfig" pflag:"-,Configuration of remote K8s cluster for array jobs"`

diff --git a/go/tasks/plugins/array/k8s/monitor.go b/go/tasks/plugins/array/k8s/monitor.go
@@ -114,7 +114,6 @@ func LaunchAndCheckSubTasksState(ctx context.Context, tCtx core.TaskExecutionCon
 		if monitorResult != MonitorSuccess {
 			return currentState, logLinks, err
 		}
-
 	}
 
 	newState = newState.SetArrayStatus(*newArrayStatus)
-Original file line number
+Diff line change
@@ Expand Up @@
     		if monitorResult != MonitorSuccess {
     			return currentState, logLinks, err
     		}
     	}
     	newState = newState.SetArrayStatus(*newArrayStatus)
@@ Expand Down @@