Rename scan_node_manager_validators_events

Signed-off-by: cyc60 <avsysoev60@gmail.com>

Author: cyc60

src/commands/node_manager_start.py

@@ -26,7 +26,7 @@
     LOG_PLAIN,
     settings,
 )
-from src.node_manager.execution import scan_validators_events
+from src.node_manager.execution import scan_node_manager_validators_events
 from src.node_manager.startup_check import startup_checks
 from src.node_manager.tasks import NodeManagerTask, StateSyncTask
 from src.validators.database import (
@@ -215,7 +215,7 @@ async def _start(
         chain_state = await get_chain_finalized_head()
 
         logger.info('Syncing validator events...')
-        await scan_validators_events(
+        await scan_node_manager_validators_events(
             operator_address=operator_address,
             block_number=chain_state.block_number,
             is_startup=True,

src/node_manager/execution.py

@@ -56,7 +56,7 @@ async def process_events(self, events: list[EventData], to_block: BlockNumber) -
         CheckpointCrud().update_validators_checkpoint(block_number=to_block)
 
 
-async def scan_validators_events(
+async def scan_node_manager_validators_events(
     operator_address: ChecksumAddress, block_number: BlockNumber, is_startup: bool
 ) -> None:
     """Scans new vault and network validators for the given block number."""

src/node_manager/tasks.py

@@ -16,7 +16,7 @@
 from src.config.settings import settings
 from src.node_manager.execution import (
     fetch_operator_state_from_ipfs,
-    scan_validators_events,
+    scan_node_manager_validators_events,
     submit_state_sync_transaction,
 )
 from src.node_manager.oracles import (
@@ -49,10 +49,10 @@ def __init__(
 
     async def process_block(self, interrupt_handler: InterruptHandler) -> None:
         chain_head = await get_chain_finalized_head()
-        await scan_validators_events(
+        await scan_node_manager_validators_events(
             operator_address=self.operator_address,
             block_number=chain_head.block_number,
-            is_startup=True,
+            is_startup=False,
         )
 
         if not await check_gas_price(high_priority=True):