Added comment to explain change in plan logic for UpdateOld endpoints

kubernetes-sigs · Oct 22, 2024 · 1292dac · 1292dac
1 parent d378655
commit 1292dac
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/plan/plan.go b/plan/plan.go
@@ -277,6 +277,8 @@ func (p *Plan) Calculate() *Plan {
 	if p.OwnerID != "" {
 		changes.Delete = endpoint.FilterEndpointsByOwnerID(p.OwnerID, changes.Delete)
 		changes.Delete = endpoint.RemoveDuplicates(changes.Delete)
+		// When running a migration we don't want to filter out endpoint duplicates on ownerId value so that old records
+		// are deleted correctly
 		if !hasMig {
 			changes.UpdateOld = endpoint.FilterEndpointsByOwnerID(p.OwnerID, changes.UpdateOld)
 		}