From aa7d35d19c98f460d371b66f6ac045906ee0748b Mon Sep 17 00:00:00 2001 From: Tyler Hobbs Date: Thu, 24 Apr 2014 15:12:58 -0500 Subject: [PATCH] Revert "Retry on received == required_responses in DCRP.on_read_timeout" This reverts commit c40a1aa79e4721f7892be787eef3c3fe0f324959. --- CHANGELOG.rst | 2 -- cassandra/policies.py | 2 +- 2 files changed, 1 insertion(+), 3 deletions(-) diff --git a/CHANGELOG.rst b/CHANGELOG.rst index 514019c1..c53c6731 100644 --- a/CHANGELOG.rst +++ b/CHANGELOG.rst @@ -10,8 +10,6 @@ Bug Fixes closing excess connections * Avoid handling a node coming up multiple times due to a reconnection attempt succeeding close to the same time that an UP notification is pushed -* Correctly retry when received_responses == required_responses in - DowngradingConsistencyRetryPolicy.on_read_timeout() (PYTHON-55) 1.1.1 ===== diff --git a/cassandra/policies.py b/cassandra/policies.py index bd41e253..2d538c2d 100644 --- a/cassandra/policies.py +++ b/cassandra/policies.py @@ -772,7 +772,7 @@ class DowngradingConsistencyRetryPolicy(RetryPolicy): received_responses, data_retrieved, retry_num): if retry_num != 0: return (self.RETHROW, None) - elif received_responses <= required_responses: + elif received_responses < required_responses: return self._pick_consistency(received_responses) elif not data_retrieved: return (self.RETRY, consistency)