Allow protocol to be set in RedisSettings

python-arq · Dec 12, 2024 · 6e27803 · 6e27803
1 parent 2f752e2
commit 6e27803
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/arq/connections.py b/arq/connections.py
@@ -45,6 +45,7 @@ class RedisSettings:
     conn_retries: int = 5
     conn_retry_delay: int = 1
     max_connections: Optional[int] = None
+    protocol: Optional[int] = 2
 
     sentinel: bool = False
     sentinel_master: str = 'mymaster'
@@ -266,6 +267,7 @@ def pool_factory(*args: Any, **kwargs: Any) -> ArqRedis:
             retry_on_timeout=settings.retry_on_timeout,
             retry_on_error=settings.retry_on_error,
             max_connections=settings.max_connections,
+            protocol=settings.protocol,
         )
 
     while True: