PR comments

Signed-off-by: Jeev B <[email protected]>

flyteplugins/go/tasks/plugins/k8s/kfoperators/mpi/mpi.go

@@ -126,10 +126,10 @@ func (mpiOperatorResourceHandler) BuildResource(ctx context.Context, taskCtx plu
 	}
 
 	if *workerReplicaSpec.Replicas <= 0 {
-		return nil, fmt.Errorf("number of worker should be more then 0")
+		return nil, fmt.Errorf("number of workers must be greater than 0")
 	}
 	if *launcherReplicaSpec.Replicas <= 0 {
-		return nil, fmt.Errorf("number of launch worker should be more then 0")
+		return nil, fmt.Errorf("number of launchers must be greater than 0")
 	}
 
 	jobSpec := kubeflowv1.MPIJobSpec{

flyteplugins/go/tasks/plugins/k8s/kfoperators/pytorch/pytorch.go

@@ -113,7 +113,7 @@ func (pytorchOperatorResourceHandler) BuildResource(ctx context.Context, taskCtx
 	}
 
 	if *workerReplicaSpec.Replicas <= 0 {
-		return nil, fmt.Errorf("number of worker should be more then 0")
+		return nil, fmt.Errorf("number of workers must be greater than 0")
 	}
 
 	jobSpec := kubeflowv1.PyTorchJobSpec{

flyteplugins/go/tasks/plugins/k8s/kfoperators/tensorflow/tensorflow.go

@@ -120,7 +120,7 @@ func (tensorflowOperatorResourceHandler) BuildResource(ctx context.Context, task
 	}
 
 	if v, ok := replicaSpecMap[kubeflowv1.TFJobReplicaTypeWorker]; !ok || *v.Replicas <= 0 {
-		return nil, fmt.Errorf("number of worker should be more then 0")
+		return nil, fmt.Errorf("number of workers must be greater than 0")
 	}
 
 	jobSpec := kubeflowv1.TFJobSpec{