review fix

frontik/service_discovery.py

@@ -109,19 +109,20 @@ def __init__(
         self.consul_weight_total_timeout_sec = options.consul_weight_total_timeout_sec
         self.consul_weight_consistency_mode = ConsistencyMode(options.consul_weight_consistency_mode.lower())
         self.consul_cache_initial_warmup_timeout_sec = options.consul_cache_initial_warmup_timeout_sec
-        self.weight = None
+        self.weight: int | None = None
 
     async def register_service(self) -> None:
         address = _get_service_address(self.options)
         http_check = _create_http_check(self.options, address)
         await self._async_register(address, http_check)
         while True:
             try:
+                await asyncio.sleep(options.consul_cache_backoff_delay_seconds)
                 await self._async_register(address, http_check)
             except Exception as exc:
                 log.exception('Failed to register %s: %s', self.service_id, exc)
 
-    async def _async_register(self, address, http_check):
+    async def _async_register(self, address: str | None, http_check: dict) -> None:
         index, value = await self.consul.kv.get(
             f'host/{self.hostname}/weight',
             wait=self.consul_weight_watch_seconds,
@@ -130,7 +131,7 @@ async def _async_register(self, address, http_check):
         )
         weight = _get_weight_or_default(value)
         if self.weight == weight:
-            return weight
+            return
 
         self.weight = weight
         register_params = {