fail before defer statement

statediff/service.go

@@ -529,6 +529,9 @@ func (sds *Service) writeStateDiff(block *types.Block, parentRoot common.Hash, p
 		receipts = sds.BlockChain.GetReceiptsByHash(block.Hash())
 	}
 	tx, err := sds.indexer.PushBlock(block, receipts, totalDifficulty)
+	if err != nil {
+		return err
+	}
 	// defer handling of commit/rollback for any return case
 	defer tx.Close()
 	output := func(node StateNode) error {