diff --git a/pybtc/connector/block_loader.py b/pybtc/connector/block_loader.py index 5bc3ed8..2c8acf8 100644 --- a/pybtc/connector/block_loader.py +++ b/pybtc/connector/block_loader.py @@ -72,7 +72,7 @@ class BlockLoader: if self.last_batch_size < 8000000: self.rpc_batch_limit += 10 elif self.last_batch_size > 50000000 and self.rpc_batch_limit > 10: - self.rpc_batch_limit = 50 + self.rpc_batch_limit = 40 if self.last_batch_size > 400: self.last_batch_size = 400 for i in self.worker_busy: @@ -186,7 +186,7 @@ class BlockLoader: self.last_batch_size = len(msg) for i in blocks: self.parent.block_preload.set(i, blocks[i]) - if blocks and index == len(self.worker_busy) - 1: + if blocks: self.parent.utxo.checkpoints.append(i) diff --git a/pybtc/connector/utxo.py b/pybtc/connector/utxo.py index 36b6972..d0772a0 100644 --- a/pybtc/connector/utxo.py +++ b/pybtc/connector/utxo.py @@ -54,6 +54,7 @@ class UTXO(): if not self.checkpoints: return self.save_process = True try: + self.log.critical("create checkpoint") i = self.cached.peek_last_item() self.checkpoints = sorted(self.checkpoints) checkpoint = self.checkpoints.pop(0)