Report new Postgres CR error when previously incorrect one is being updated (#449)
This commit is contained in:
parent
38f7a3dac6
commit
1109c861fb
|
|
@ -385,8 +385,14 @@ func (c *Controller) queueClusterEvent(informerOldSpec, informerNewSpec *acidv1.
|
||||||
if informerOldSpec != nil { //update, delete
|
if informerOldSpec != nil { //update, delete
|
||||||
uid = informerOldSpec.GetUID()
|
uid = informerOldSpec.GetUID()
|
||||||
clusterName = util.NameFromMeta(informerOldSpec.ObjectMeta)
|
clusterName = util.NameFromMeta(informerOldSpec.ObjectMeta)
|
||||||
|
|
||||||
|
// user is fixing previously incorrect spec
|
||||||
if eventType == EventUpdate && informerNewSpec.Error == "" && informerOldSpec.Error != "" {
|
if eventType == EventUpdate && informerNewSpec.Error == "" && informerOldSpec.Error != "" {
|
||||||
eventType = EventSync
|
eventType = EventSync
|
||||||
|
}
|
||||||
|
|
||||||
|
// set current error to be one of the new spec if present
|
||||||
|
if informerNewSpec != nil {
|
||||||
clusterError = informerNewSpec.Error
|
clusterError = informerNewSpec.Error
|
||||||
} else {
|
} else {
|
||||||
clusterError = informerOldSpec.Error
|
clusterError = informerOldSpec.Error
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue