diff --git a/wallet/chainntfns.go b/wallet/chainntfns.go
index e9af9dc..d9bf059 100644
--- a/wallet/chainntfns.go
+++ b/wallet/chainntfns.go
@@ -55,12 +55,9 @@ func (w *Wallet) handleChainNotifications() {
 		case chain.FilteredBlockConnected:
 			// Atomically update for the whole block.
 			err = walletdb.Update(w.db, func(tx walletdb.ReadWriteTx) error {
-				err := w.connectBlock(tx, *n.Block)
-				if err != nil {
-					return err
-				}
+				var err error
 				for _, rec := range n.RelevantTxs {
-					err := w.addRelevantTx(tx, rec, n.Block)
+					err = w.addRelevantTx(tx, rec, n.Block)
 					if err != nil {
 						return err
 					}