fix(controller): vertex nil check for edge listing. Fixes #352 (#353)

numaproj · Nov 15, 2022 · 6c8f03f · 6c8f03f
1 parent d872728
commit 6c8f03f
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/pkg/apis/numaflow/v1alpha1/pipeline_types.go b/pkg/apis/numaflow/v1alpha1/pipeline_types.go
@@ -89,6 +89,9 @@ func (p Pipeline) ListAllEdges() []Edge {
 	for _, e := range p.Spec.Edges {
 		edgeCopy := e.DeepCopy()
 		toVertex := p.GetVertex(e.To)
+		if toVertex == nil {
+			continue
+		}
 		if toVertex.UDF == nil || toVertex.UDF.GroupBy == nil {
 			// Clean up parallelism if downstream vertex is not a reduce UDF.
 			// This has been validated by the controller, harmless to do it here.