diff --git a/management/server/peer.go b/management/server/peer.go index c9b0fcfee..ff898f56c 100644 --- a/management/server/peer.go +++ b/management/server/peer.go @@ -400,6 +400,9 @@ func (am *DefaultAccountManager) DeletePeer(ctx context.Context, accountID, peer eventsToStore, err = deletePeers(ctx, am, transaction, accountID, userID, []*nbpeer.Peer{peer}) return err }) + if err != nil { + return err + } for _, storeEvent := range eventsToStore { storeEvent()