Run HarvestTask only if needed

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

Author: cyc60

src/commands/start.py

@@ -294,7 +294,6 @@ async def main() -> None:
     logger.info('Started operator service')
     with InterruptHandler() as interrupt_handler:
         while not interrupt_handler.exit:
-            await HarvestTask().run()
             await ValidatorsTask(
                 keystores=keystores,
                 remote_signer_config=remote_signer_config,
@@ -304,6 +303,8 @@ async def main() -> None:
                 keystores=keystores,
                 remote_signer_config=remote_signer_config,
             ).run()
+            if settings.harvest_vault:
+                await HarvestTask().run()
             await MetricsTask().run()
             await WalletTask().run()
 

src/harvest/tasks.py

@@ -13,9 +13,6 @@
 class HarvestTask(BaseTask):
     async def process_block(self) -> None:
         """Check vault state and send harvest transaction if needed."""
-        if not settings.harvest_vault:
-            return
-
         if not await keeper_contract.can_harvest(settings.vault):
             return