Start listener from block lag

This commit is contained in:
Luke Van Seters 2021-12-20 12:37:20 -05:00
parent cfa3443f88
commit 6e8d898cb0

View File

@ -65,14 +65,10 @@ async def inspect_next_block(
if last_written_block is None: if last_written_block is None:
# maintain lag if no blocks written yet # maintain lag if no blocks written yet
last_written_block = latest_block_number - 1 last_written_block = latest_block_number - BLOCK_NUMBER_LAG - 1
if last_written_block < (latest_block_number - BLOCK_NUMBER_LAG): if last_written_block < (latest_block_number - BLOCK_NUMBER_LAG):
block_number = ( block_number = last_written_block + 1
latest_block_number
if last_written_block is None
else last_written_block + 1
)
logger.info(f"Writing block: {block_number}") logger.info(f"Writing block: {block_number}")