receipt transfer: move interval to dynamic config

validator/app/src/compute_horde_validator/settings.py

@@ -294,6 +294,11 @@ def wrapped(*args, **kwargs):
         "Whether receipt transfer between miners and validators should be enabled",
         bool,
     ),
+    "DYNAMIC_RECEIPT_TRANSFER_INTERVAL": (
+        2,
+        "Seconds between consecutive receipt polling",
+        int,
+    ),
 }
 DYNAMIC_CONFIG_CACHE_TIMEOUT = 300
 

validator/app/src/compute_horde_validator/validator/management/commands/transfer_receipts.py

@@ -79,15 +79,16 @@ def add_arguments(self, parser):
             help="Only for debug: IP port of miner to fetch receipts from",
         )
         parser.add_argument(
-            "--interval",
-            type=float,
-            help="If provided, runs in daemon mode and polls for changes every `interval` seconds.",
+            "--daemon",
+            action="store_true",
+            default=False,
+            help="Run indefinitely. (otherwise performs a single transfer)",
         )
 
     @async_to_sync
     async def handle(
         self,
-        interval: float | None,
+        daemon: bool,
         debug_miner_hotkey: str | None,
         debug_miner_ip: str | None,
         debug_miner_port: int | None,
@@ -144,16 +145,16 @@ async def miners():
             - less timeouts due to CPU time being stolen by CPU heavy tasks
         """
 
-        if interval is None:
-            await self.run_once(cutoff, miners)
-        else:
+        if daemon:
             while True:
                 try:
-                    await self.run_in_loop(interval, cutoff, miners)
+                    await self.run_in_loop(cutoff, miners)
                 except TransferIsDisabled:
                     # Sleep instead of exiting in case the transfer gets dynamically re-enabled.
                     logger.info("Transfer is currently disabled. Sleeping for a minute.")
                     await asyncio.sleep(60)
+        else:
+            await self.run_once(cutoff, miners)
 
     async def run_once(
         self, cutoff: datetime, miners: Callable[[], Awaitable[list[MinerInfo]]]
@@ -170,7 +171,7 @@ async def run_once(
             )
 
     async def run_in_loop(
-        self, interval: float, cutoff: datetime, miners: Callable[[], Awaitable[list[MinerInfo]]]
+        self, cutoff: datetime, miners: Callable[[], Awaitable[list[MinerInfo]]]
     ) -> None:
         """
         Do a full catch-up + listen for changes in latest 2 pages indefinitely
@@ -200,7 +201,6 @@ async def run_in_loop(
                 ),
                 # Keep up with latest pages continuously in parallel
                 self.keep_up(
-                    interval=interval,
                     miners=miners,
                     session=session,
                     semaphore=asyncio.Semaphore(50),
@@ -247,7 +247,6 @@ async def catch_up(
 
     async def keep_up(
         self,
-        interval: float,
         miners: Callable[[], Awaitable[list[MinerInfo]]],
         session: aiohttp.ClientSession,
         semaphore: asyncio.Semaphore,
@@ -257,6 +256,7 @@ async def keep_up(
         """
         while True:
             await self._throw_if_disabled()
+            interval: int = await aget_config("DYNAMIC_RECEIPT_TRANSFER_INTERVAL")
 
             start_time = time.monotonic()
             current_page = LocalFilesystemPagedReceiptStore.current_page()

validator/envs/runner/data/docker-compose.yml

@@ -224,7 +224,7 @@ services:
     init: true
     restart: unless-stopped
     env_file: ./.env
-    command: python manage.py transfer_receipts --interval 2
+    command: python manage.py transfer_receipts --daemon
     depends_on:
       - redis
       - db