wait fixed 1s between all websocket connections

Author: merolish

apps/hip-3-pusher/src/pusher/hermes_listener.py

@@ -3,7 +3,7 @@
 from loguru import logger
 import time
 import websockets
-from tenacity import retry, retry_if_exception_type, wait_exponential
+from tenacity import retry, retry_if_exception_type, wait_fixed
 
 from pusher.config import Config, STALE_TIMEOUT_SECONDS
 from pusher.exception import StaleConnectionError
@@ -38,7 +38,7 @@ async def subscribe_all(self):
 
     @retry(
         retry=retry_if_exception_type(Exception),
-        wait=wait_exponential(multiplier=1, min=1, max=10),
+        wait=wait_fixed(1),
         reraise=True,
     )
     async def subscribe_single(self, url):

apps/hip-3-pusher/src/pusher/hyperliquid_listener.py

@@ -4,7 +4,7 @@
 
 import websockets
 from loguru import logger
-from tenacity import retry, retry_if_exception_type, wait_exponential
+from tenacity import retry, retry_if_exception_type, wait_fixed
 import time
 
 from pusher.config import Config, STALE_TIMEOUT_SECONDS
@@ -51,7 +51,7 @@ async def subscribe_all(self):
 
     @retry(
         retry=retry_if_exception_type(Exception),
-        wait=wait_exponential(multiplier=1, min=1, max=10),
+        wait=wait_fixed(1),
         reraise=True,
     )
     async def subscribe_single(self, url):

apps/hip-3-pusher/src/pusher/lazer_listener.py

@@ -3,7 +3,7 @@
 from loguru import logger
 import time
 import websockets
-from tenacity import retry, retry_if_exception_type, wait_exponential
+from tenacity import retry, retry_if_exception_type, wait_fixed
 
 from pusher.config import Config, STALE_TIMEOUT_SECONDS
 from pusher.exception import StaleConnectionError
@@ -42,7 +42,7 @@ async def subscribe_all(self):
 
     @retry(
         retry=retry_if_exception_type(Exception),
-        wait=wait_exponential(multiplier=1, min=1, max=10),
+        wait=wait_fixed(1),
         reraise=True,
     )
     async def subscribe_single(self, router_url):