diff --git a/pybtc/connector/connector.py b/pybtc/connector/connector.py
index 052f56c..b615b8f 100644
--- a/pybtc/connector/connector.py
+++ b/pybtc/connector/connector.py
@@ -363,10 +363,7 @@ class Connector:
 
             if self.utxo_data:
                 checkpoint = self.utxo.checkpoint
-                try:
-                    self.log.critical("append checkpoint " + str( block["checkpoint"]))
-
-                    self.utxo.checkpoints.append(block["checkpoint"])
+                try: self.utxo.checkpoints.append(block["checkpoint"])
                 except: pass
                 if len(self.utxo.cached) > self.utxo.size_limit and \
                    not self.utxo.save_process and \
@@ -429,7 +426,7 @@ class Connector:
                                                                    self.utxo.deleted_utxo,
                                                                    self.utxo.loaded_utxo
                                                            ))
-                self.log.debug("Preload coins cached/destoyed  -> %s-%s [%s];" % (self.yy, self.aa, self.tt))
+                self.log.debug("Preload coins chached/destoyed  -> %s-%s [%s];" % (self.yy, self.aa, self.tt))
                 self.log.debug("Coins %s; destroyed %s; unspent %s;" % (self.coins,
                                                                      self.destroyed_coins,
                                                                      self.coins - self.destroyed_coins))
diff --git a/pybtc/connector/utxo.py b/pybtc/connector/utxo.py
index dc4eb39..2fad4e5 100644
--- a/pybtc/connector/utxo.py
+++ b/pybtc/connector/utxo.py
@@ -93,6 +93,14 @@ class UTXO():
             self.log.critical("create checkpoint error")
             self.log.critical(str(traceback.format_exc()))
 
+    def rocksdb_atomic_batch(self):
+        batch = rocksdb.WriteBatch()
+        [batch.delete(k) for k in self.pending_deleted]
+        for k in self.pending_utxo:
+            batch.put(k[0], k[1])
+        batch.put(b"last_block", int_to_bytes(self.checkpoint))
+        batch.put(b"last_cached_block", int_to_bytes(self.deleted_last_block))
+        self.db.write(batch)
 
     async def save_checkpoint(self):
         # save to db tail from cache
@@ -101,15 +109,7 @@ class UTXO():
         try:
             self.write_to_db = True
             if not self.checkpoint: return
-
-            batch = rocksdb.WriteBatch()
-            [batch.delete(k) for k in self.pending_deleted]
-            for k in self.pending_utxo:
-                batch.put(k[0], k[1])
-            batch.put(b"last_block", int_to_bytes(self.checkpoint))
-            batch.put(b"last_cached_block", int_to_bytes(self.deleted_last_block))
-            self.db.write(batch)
-
+            await self.loop.run_in_executor(None, self.rocksdb_atomic_batch, self)
             self.saved_utxo += len(self.pending_utxo)
             self.deleted_utxo += len(self.pending_deleted)
             self.pending_deleted = set()