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)