diff --git a/flyteplugins/go/tasks/plugins/k8s/ray/config.go b/flyteplugins/go/tasks/plugins/k8s/ray/config.go index 27e5c070716..3f79ed958e9 100644 --- a/flyteplugins/go/tasks/plugins/k8s/ray/config.go +++ b/flyteplugins/go/tasks/plugins/k8s/ray/config.go @@ -26,7 +26,7 @@ var ( Defaults: DefaultConfig{ HeadNode: NodeConfig{ StartParameters: map[string]string{ - // Disable usage reporting by default: https://docs.ray.io/en/latest/cluster/deusage-stats.html + // Disable usage reporting by default: https://docs.ray.io/en/latest/cluster/usage-stats.html DisableUsageStatsStartParameter: "true", }, IPAddress: "$MY_POD_IP", diff --git a/flyteplugins/go/tasks/plugins/k8s/ray/config_test.go b/flyteplugins/go/tasks/plugins/k8s/ray/config_test.go index d19c047ca61..07b0c2842a1 100644 --- a/flyteplugins/go/tasks/plugins/k8s/ray/config_test.go +++ b/flyteplugins/go/tasks/plugins/k8s/ray/config_test.go @@ -32,6 +32,6 @@ func TestLoadDefaultServiceAccountConfig(t *testing.T) { t.Run("serviceAccount", func(t *testing.T) { config := GetConfig() - assert.Equal(t, config.ServiceAccount, "default") + assert.Equal(t, config.ServiceAccount, "") }) } diff --git a/flyteplugins/go/tasks/plugins/k8s/ray/ray.go b/flyteplugins/go/tasks/plugins/k8s/ray/ray.go index 95a87f4efab..9b107190337 100644 --- a/flyteplugins/go/tasks/plugins/k8s/ray/ray.go +++ b/flyteplugins/go/tasks/plugins/k8s/ray/ray.go @@ -190,7 +190,7 @@ func constructRayJob(taskCtx pluginsCore.TaskExecutionContext, rayJob plugins.Ra } serviceAccountName := flytek8s.GetServiceAccountNameFromTaskExecutionMetadata(taskCtx.TaskExecutionMetadata()) - if len(serviceAccountName) == 0 { + if len(serviceAccountName) == 0 || cfg.ServiceAccount != "" { serviceAccountName = cfg.ServiceAccount }