connect_retry_timeout -> connect_retries_timeout

celery · Oct 12, 2022 · f46918e · f46918e
1 parent c16aacb
commit f46918e
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/kombu/connection.py b/kombu/connection.py
@@ -867,8 +867,8 @@ def _extract_failover_opts(self):
                 conn_opts['interval_step'] = transport_opts['interval_step']
             if 'interval_max' in transport_opts:
                 conn_opts['interval_max'] = transport_opts['interval_max']
-            if 'connect_retry_timeout' in transport_opts:
-                conn_opts['timeout'] = transport_opts['connect_retry_timeout']
+            if 'connect_retries_timeout' in transport_opts:
+                conn_opts['timeout'] = transport_opts['connect_retries_timeout']
         return conn_opts
 
     @property

diff --git a/t/unit/test_connection.py b/t/unit/test_connection.py
@@ -719,7 +719,7 @@ def test_connection_failover_with_total_timeout(self):
             ['server1', 'server2'],
             transport=TimeoutingTransport,
             connect_timeout=1,
-            transport_options={'connect_retry_timeout': 2, 'interval_start': 0,
+            transport_options={'connect_retries_timeout': 2, 'interval_start': 0,
                                'interval_step': 0},
         ) as conn:
             conn._establish_connection = Mock(