add parallel policy as owner references

Signed-off-by: rahulii <[email protected]>
knative · Aug 8, 2024 · 35e475b · 35e475b
1 parent 43fb57b
commit 35e475b
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 0 deletions.
diff --git a/pkg/reconciler/parallel/parallel_test.go b/pkg/reconciler/parallel/parallel_test.go
@@ -1519,6 +1519,10 @@ func makeIngressChannelEventPolicy(parallelName, channelName, parallelEventPolic
 				APIVersion: "flows.knative.dev/v1",
 				Kind:       "Parallel",
 				Name:       parallelName,
+			}, {
+				APIVersion: "eventing.knative.dev/v1alpha1",
+				Kind:       "EventPolicy",
+				Name:       parallelEventPolicyName,
 			},
 		}...),
 		WithEventPolicyLabels(resources.LabelsForParallelChannelsEventPolicy(parallelName)),

diff --git a/pkg/reconciler/parallel/resources/eventpolicy.go b/pkg/reconciler/parallel/resources/eventpolicy.go
@@ -92,6 +92,12 @@ func MakeEventPolicyForParallelIngressChannel(p *flowsv1.Parallel, ingressChanne
 					APIVersion: flowsv1.SchemeGroupVersion.String(),
 					Kind:       parallelKind,
 					Name:       p.Name,
+					UID:        p.UID,
+				}, {
+					APIVersion: eventingv1alpha1.SchemeGroupVersion.String(),
+					Kind:       "EventPolicy",
+					Name:       parallelPolicy.Name,
+					UID:        parallelPolicy.UID,
 				},
 			},
 			Labels: LabelsForParallelChannelsEventPolicy(p.Name),