diff --git a/store/store.go b/store/store.go index fe2e2aaa0..54dd0f1a1 100644 --- a/store/store.go +++ b/store/store.go @@ -354,8 +354,10 @@ func (s *store) CompareAndDelete(nodePath string, prevValue string, prevIndex ui s.WatcherHub.notifyWatchers(e, path, true) } - // delete a key-value pair, no error should happen - n.Remove(false, false, callback) + err = n.Remove(false, false, callback) + if err != nil { + return nil, err + } s.WatcherHub.notify(e) s.Stats.Inc(CompareAndDeleteSuccess)