From 34ed927af3857a743276568813a48c1b7ddc6747 Mon Sep 17 00:00:00 2001 From: vvmruder Date: Wed, 10 May 2023 11:15:50 +0200 Subject: [PATCH] Update connections.py 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 d4fc4434..a1c0ba4b 100644 --- a/arq/connections.py +++ b/arq/connections.py @@ -266,7 +266,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__,