feat(backend): Include namespace in Pipeline API model. Part of kubef…

…low#4197 (kubeflow#8375)
jlyaoyuli · Jan 5, 2023 · 6d8458b · 6d8458b
1 parent 3668c3f
commit 6d8458b
Showing 1 changed file with 20 additions and 6 deletions.
diff --git a/backend/src/apiserver/server/api_converter.go b/backend/src/apiserver/server/api_converter.go
@@ -74,13 +74,27 @@ func ToApiPipeline(pipeline *model.Pipeline) *api.Pipeline {
 		}
 	}
 
+	var resourceRefs []*api.ResourceReference
+	if len(pipeline.Namespace) > 0 {
+		resourceRefs = []*api.ResourceReference{
+			{
+				Key: &api.ResourceKey{
+					Type: api.ResourceType_NAMESPACE,
+					Id:   pipeline.Namespace,
+				},
+				Relationship: api.Relationship_OWNER,
+			},
+		}
+	}
+
 	return &api.Pipeline{
-		Id:             pipeline.UUID,
-		CreatedAt:      &timestamp.Timestamp{Seconds: pipeline.CreatedAtInSec},
-		Name:           pipeline.Name,
-		Description:    pipeline.Description,
-		Parameters:     params,
-		DefaultVersion: defaultVersion,
+		Id:                 pipeline.UUID,
+		CreatedAt:          &timestamp.Timestamp{Seconds: pipeline.CreatedAtInSec},
+		Name:               pipeline.Name,
+		Description:        pipeline.Description,
+		Parameters:         params,
+		DefaultVersion:     defaultVersion,
+		ResourceReferences: resourceRefs,
 	}
 }