diff --git a/pkg/cluster/sync.go b/pkg/cluster/sync.go index 84b9d7698..2d74086e7 100644 --- a/pkg/cluster/sync.go +++ b/pkg/cluster/sync.go @@ -125,9 +125,13 @@ func (c *Cluster) applyActions(actions []Action) (err error) { } for action := range uniqueActions { - if dontStop, err := action.process(); err != nil && !dontStop { + if critical, err := action.process(); err != nil { c.logger.Errorf("Can't apply action %s: %v", action.name(), err) } + + if critical == true { + return err + } } }