diff --git a/crawlers/mooncrawl/mooncrawl/ethcrawler.py b/crawlers/mooncrawl/mooncrawl/ethcrawler.py index e04d6dae..e89e4781 100644 --- a/crawlers/mooncrawl/mooncrawl/ethcrawler.py +++ b/crawlers/mooncrawl/mooncrawl/ethcrawler.py @@ -97,6 +97,13 @@ def ethcrawler_blocks_sync_handler(args: argparse.Namespace) -> None: ) if latest_stored_block_number is None: latest_stored_block_number = 0 + + if latest_stored_block_number >= latest_block_number: + logger.info( + f"Synchronization is unnecessary for blocks {latest_stored_block_number}-{latest_block_number - 1}" + ) + time.sleep(5) + continue block_number_difference = latest_block_number - 1 - latest_stored_block_number @@ -108,17 +115,10 @@ def ethcrawler_blocks_sync_handler(args: argparse.Namespace) -> None: time.sleep(5) continue else: - bottom_block_number = latest_block_number - args.confirmations + bottom_block_number = latest_stored_block_number + 1 else: bottom_block_number = max(latest_stored_block_number + 1, args.start) - if latest_stored_block_number >= latest_block_number: - logger.info( - f"Synchronization is unnecessary for blocks {latest_stored_block_number}-{latest_block_number - 1}" - ) - time.sleep(5) - continue - for blocks_numbers_list in yield_blocks_numbers_lists( f"{bottom_block_number}-{latest_block_number}", order=args.order,