chore: vertex controller stop watching pod create events (numaproj#361)

dseapy · Nov 17, 2022 · 3588bf3 · 3588bf3
1 parent 1a5d424
commit 3588bf3
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/pkg/reconciler/cmd/start.go b/pkg/reconciler/cmd/start.go
@@ -173,7 +173,10 @@ func Start(namespaced bool, managedNamespace string) {
 	}
 
 	// Watch Pods
-	if err := vertexController.Watch(&source.Kind{Type: &corev1.Pod{}}, &handler.EnqueueRequestForOwner{OwnerType: &dfv1.Vertex{}, IsController: true}); err != nil {
+	if err := vertexController.Watch(&source.Kind{Type: &corev1.Pod{}}, &handler.EnqueueRequestForOwner{OwnerType: &dfv1.Vertex{}, IsController: true},
+		predicate.Funcs{
+			CreateFunc: func(event.CreateEvent) bool { return false }, // Do not watch pod create events
+		}); err != nil {
 		logger.Fatalw("Unable to watch Pods", zap.Error(err))
 	}