From 3de6d8724e25cce5cf5086a03b3452fcb3258d51 Mon Sep 17 00:00:00 2001 From: vvmruder Date: Mon, 1 Apr 2024 16:23:55 +0200 Subject: [PATCH] Update connections.py (#396) Allows values like `float('inf')` to retry infinite. This can be useful in cluster contexts where a redis service might temporarily not available for some reason but you might not want the worker to crash on that but waiting until redis is available again --- arq/connections.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/arq/connections.py b/arq/connections.py index c79ec534..63c7ab82 100644 --- a/arq/connections.py +++ b/arq/connections.py @@ -280,7 +280,7 @@ def pool_factory(*args: Any, **kwargs: Any) -> ArqRedis: except (ConnectionError, OSError, RedisError, asyncio.TimeoutError) as e: if retry < settings.conn_retries: logger.warning( - 'redis connection error %s:%s %s %s, %d retries remaining...', + 'redis connection error %s:%s %s %s, %s retries remaining...', settings.host, settings.port, e.__class__.__name__,