feat: annotation update check changed

Signed-off-by: Dillen Padhiar <[email protected]>
numaproj · Oct 4, 2023 · 5612e8b · 5612e8b
1 parent bd8af3c
commit 5612e8b
Showing 1 changed file with 13 additions and 1 deletion.
diff --git a/pkg/reconciler/pipeline/controller.go b/pkg/reconciler/pipeline/controller.go
@@ -534,9 +534,21 @@ func needsUpdate(old, new *dfv1.Pipeline) bool {
 	if !equality.Semantic.DeepEqual(old.Finalizers, new.Finalizers) {
 		return true
 	}
-	if !equality.Semantic.DeepEqual(old.GetAnnotations(), new.GetAnnotations()) {
+
+	oldAnnotations := old.GetAnnotations()
+	newAnnotations := new.GetAnnotations()
+	if oldAnnotations != nil && newAnnotations == nil {
+		return true
+	}
+	if oldAnnotations == nil && newAnnotations != nil {
 		return true
 	}
+
+	for k, v := range oldAnnotations {
+		if strings.Contains(k, "numaflow.numaproj.io/") && v != newAnnotations[k] {
+			return true
+		}
+	}
 	return false
 }