Fix chain head

Author: evgeny-stakewise

src/commands/start/base.py

@@ -130,7 +130,7 @@ async def process_block(self, interrupt_handler: InterruptHandler) -> None:
             chain_head=chain_head, interrupt_handler=interrupt_handler
         )
         await scan_validators_events(block_number=chain_head.block_number, is_startup=False)
-        subtasks = [self.validator_registration_subtask.process(chain_head=chain_head)]
+        subtasks = [self.validator_registration_subtask.process()]
         if not settings.disable_withdrawals:
             subtasks.append(self.validator_withdrawal_subtask.process())
         await asyncio.gather(*subtasks)

src/validators/tasks.py

@@ -9,6 +9,7 @@
 from web3.types import BlockNumber, Gwei, Wei
 
 from src.common.clients import execution_client
+from src.common.consensus import get_chain_latest_head
 from src.common.contracts import VaultContract, validators_registry_contract
 from src.common.execution import check_gas_price
 from src.common.harvest import get_harvest_params
@@ -46,13 +47,14 @@ def __init__(
         self.keystore = keystore
         self.relayer = relayer
 
-    async def process(self, chain_head: ChainHead) -> None:
+    async def process(self) -> None:
         if self.keystore:
             await update_unused_validator_keys_metric(
                 keystore=self.keystore,
             )
         harvest_params = await get_harvest_params(settings.vault)
 
+        chain_head = await get_chain_latest_head()
         vault_assets = await get_vault_assets(harvest_params=harvest_params, chain_head=chain_head)
         vault_assets = Gwei(max(0, vault_assets - settings.vault_min_balance_gwei))