From f46918e2539c07554543c5beaf85705ee97cf65d Mon Sep 17 00:00:00 2001 From: Marti Raudsepp Date: Wed, 12 Oct 2022 11:36:12 +0300 Subject: [PATCH] connect_retry_timeout -> connect_retries_timeout --- kombu/connection.py | 4 ++-- t/unit/test_connection.py | 2 +- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/kombu/connection.py b/kombu/connection.py index 6e11d9584..ca5a47ae9 100644 --- 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 index ad73ee354..c121cf285 100644 --- 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(