Skip to content

Commit

Permalink
Fix deletion case for extension predicates
Browse files Browse the repository at this point in the history
  • Loading branch information
timuthy committed Jun 15, 2020
1 parent daacca0 commit 890d732
Show file tree
Hide file tree
Showing 10 changed files with 4 additions and 40 deletions.
4 changes: 0 additions & 4 deletions extensions/pkg/controller/backupbucket/controller.go
Expand Up @@ -67,10 +67,6 @@ func DefaultPredicates(ignoreOperationAnnotation bool) []predicate.Predicate {
extensionspredicate.LastOperationNotSuccessful(),
extensionspredicate.IsDeleting(),
),
extensionspredicate.Or(
extensionspredicate.HasOperationAnnotation(),
predicate.GenerationChangedPredicate{},
),
}
}

Expand Down
4 changes: 0 additions & 4 deletions extensions/pkg/controller/backupentry/controller.go
Expand Up @@ -67,10 +67,6 @@ func DefaultPredicates(ignoreOperationAnnotation bool) []predicate.Predicate {
extensionspredicate.LastOperationNotSuccessful(),
extensionspredicate.IsDeleting(),
),
extensionspredicate.Or(
extensionspredicate.HasOperationAnnotation(),
predicate.GenerationChangedPredicate{},
),
}
}

Expand Down
4 changes: 0 additions & 4 deletions extensions/pkg/controller/containerruntime/controller.go
Expand Up @@ -77,10 +77,6 @@ func DefaultPredicates(ignoreOperationAnnotation bool) []predicate.Predicate {
extensionspredicate.IsDeleting(),
),
extensionspredicate.ShootNotFailed(),
extensionspredicate.Or(
extensionspredicate.HasOperationAnnotation(),
predicate.GenerationChangedPredicate{},
),
}
}

Expand Down
4 changes: 0 additions & 4 deletions extensions/pkg/controller/controlplane/controller.go
Expand Up @@ -67,10 +67,6 @@ func DefaultPredicates(ignoreOperationAnnotation bool) []predicate.Predicate {
extensionspredicate.IsDeleting(),
),
extensionspredicate.ShootNotFailed(),
extensionspredicate.Or(
extensionspredicate.HasOperationAnnotation(),
predicate.GenerationChangedPredicate{},
),
}
}

Expand Down
4 changes: 0 additions & 4 deletions extensions/pkg/controller/extension/reconciler.go
Expand Up @@ -91,10 +91,6 @@ func DefaultPredicates(ignoreOperationAnnotation bool) []predicate.Predicate {
extensionspredicate.IsDeleting(),
),
extensionspredicate.ShootNotFailed(),
extensionspredicate.Or(
extensionspredicate.HasOperationAnnotation(),
predicate.GenerationChangedPredicate{},
),
}
}

Expand Down
4 changes: 0 additions & 4 deletions extensions/pkg/controller/infrastructure/controller.go
Expand Up @@ -71,10 +71,6 @@ func DefaultPredicates(ignoreOperationAnnotation bool) []predicate.Predicate {
extensionspredicate.IsDeleting(),
),
extensionspredicate.ShootNotFailed(),
extensionspredicate.Or(
extensionspredicate.HasOperationAnnotation(),
predicate.GenerationChangedPredicate{},
),
}
}

Expand Down
4 changes: 0 additions & 4 deletions extensions/pkg/controller/network/controller.go
Expand Up @@ -67,10 +67,6 @@ func DefaultPredicates(ignoreOperationAnnotation bool) []predicate.Predicate {
extensionspredicate.IsDeleting(),
),
extensionspredicate.ShootNotFailed(),
extensionspredicate.Or(
extensionspredicate.HasOperationAnnotation(),
predicate.GenerationChangedPredicate{},
),
}
}

Expand Down
4 changes: 0 additions & 4 deletions extensions/pkg/controller/operatingsystemconfig/controller.go
Expand Up @@ -72,10 +72,6 @@ func DefaultPredicates(ignoreOperationAnnotation bool) []predicate.Predicate {
extensionspredicate.LastOperationNotSuccessful(),
extensionspredicate.IsDeleting(),
),
extensionspredicate.Or(
extensionspredicate.HasOperationAnnotation(),
predicate.GenerationChangedPredicate{},
),
}
}

Expand Down
4 changes: 0 additions & 4 deletions extensions/pkg/controller/worker/controller.go
Expand Up @@ -71,10 +71,6 @@ func DefaultPredicates(ignoreOperationAnnotation bool) []predicate.Predicate {
extensionspredicate.IsDeleting(),
),
extensionspredicate.ShootNotFailed(),
extensionspredicate.Or(
extensionspredicate.HasOperationAnnotation(),
predicate.GenerationChangedPredicate{},
),
}
}

Expand Down
8 changes: 4 additions & 4 deletions extensions/pkg/predicate/predicate.go
Expand Up @@ -166,7 +166,7 @@ func HasOperationAnnotation() predicate.Predicate {
}), CreateTrigger, UpdateNewTrigger, GenericTrigger)
}

// LastOperationNotSuccessful is a predicate for unsuccessful last operations for creation events.
// LastOperationNotSuccessful is a predicate for unsuccessful last operations **only** for creation events.
func LastOperationNotSuccessful() predicate.Predicate {
operationNotSucceeded := func(obj runtime.Object) bool {
acc, err := extensions.Accessor(obj)
Expand All @@ -184,13 +184,13 @@ func LastOperationNotSuccessful() predicate.Predicate {
return operationNotSucceeded(event.Object)
},
UpdateFunc: func(event event.UpdateEvent) bool {
return operationNotSucceeded(event.ObjectNew)
return false
},
GenericFunc: func(event event.GenericEvent) bool {
return operationNotSucceeded(event.Object)
return false
},
DeleteFunc: func(event event.DeleteEvent) bool {
return operationNotSucceeded(event.Object)
return false
},
}
}
Expand Down

0 comments on commit 890d732

Please sign in to comment.