diff --git a/flyteplugins/go/tasks/plugins/k8s/ray/config_flags.go b/flyteplugins/go/tasks/plugins/k8s/ray/config_flags.go index 8a750ab48b..5048869eab 100755 --- a/flyteplugins/go/tasks/plugins/k8s/ray/config_flags.go +++ b/flyteplugins/go/tasks/plugins/k8s/ray/config_flags.go @@ -59,7 +59,6 @@ func (cfg Config) GetPFlagSet(prefix string) *pflag.FlagSet { cmdFlags.String(fmt.Sprintf("%v%v", prefix, "remoteClusterConfig.endpoint"), defaultConfig.RemoteClusterConfig.Endpoint, " Remote K8s cluster endpoint") cmdFlags.Bool(fmt.Sprintf("%v%v", prefix, "remoteClusterConfig.enabled"), defaultConfig.RemoteClusterConfig.Enabled, " Boolean flag to enable or disable") cmdFlags.Bool(fmt.Sprintf("%v%v", prefix, "enableUsageStats"), defaultConfig.EnableUsageStats, "Enable usage stats for ray jobs. These stats are submitted to usage-stats.ray.io per https://docs.ray.io/en/latest/cluster/usage-stats.html") - cmdFlags.String(fmt.Sprintf("%v%v", prefix, "kubeRayCrdVersion"), defaultConfig.KubeRayCrdVersion, "Version of the Ray CRD to use when creating RayClusters or RayJobs.") cmdFlags.String(fmt.Sprintf("%v%v", prefix, "serviceAccount"), defaultConfig.ServiceAccount, "The k8s service account to run as") return cmdFlags } diff --git a/flyteplugins/go/tasks/plugins/k8s/ray/config_flags_test.go b/flyteplugins/go/tasks/plugins/k8s/ray/config_flags_test.go index 6938ee398f..05871adc51 100755 --- a/flyteplugins/go/tasks/plugins/k8s/ray/config_flags_test.go +++ b/flyteplugins/go/tasks/plugins/k8s/ray/config_flags_test.go @@ -225,20 +225,6 @@ func TestConfig_SetFlags(t *testing.T) { } }) }) - t.Run("Test_kubeRayCrdVersion", func(t *testing.T) { - - t.Run("Override", func(t *testing.T) { - testValue := "1" - - cmdFlags.Set("kubeRayCrdVersion", testValue) - if vString, err := cmdFlags.GetString("kubeRayCrdVersion"); err == nil { - testDecodeJson_Config(t, fmt.Sprintf("%v", vString), &actual.KubeRayCrdVersion) - - } else { - assert.FailNow(t, err.Error()) - } - }) - }) t.Run("Test_serviceAccount", func(t *testing.T) { t.Run("Override", func(t *testing.T) {