Merge 6c9f374 into 445fc58

flyteorg · Oct 3, 2023 · 591d066 · 591d066
2 parents 445fc58 + 6c9f374
commit 591d066
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/go/tasks/plugins/k8s/ray/ray.go b/go/tasks/plugins/k8s/ray/ray.go
@@ -51,6 +51,7 @@ func (rayJobResourceHandler) BuildResource(ctx context.Context, taskCtx pluginsC
 		return nil, flyteerr.Errorf(flyteerr.BadTaskSpecification, "nil task specification")
 	}
 
+	config := taskTemplate.GetConfig()
 	rayJob := plugins.RayJob{}
 	err = utils.UnmarshalStruct(taskTemplate.GetCustom(), &rayJob)
 	if err != nil {
@@ -168,6 +169,7 @@ func (rayJobResourceHandler) BuildResource(ctx context.Context, taskCtx pluginsC
 		RuntimeEnv:               rayJob.RuntimeEnv,
 	}
 
+	objectMeta.Namespace = config["namespace"]
 	rayJobObject := rayv1alpha1.RayJob{
 		TypeMeta: metav1.TypeMeta{
 			Kind:       KindRayJob,