From c40a1aa79e4721f7892be787eef3c3fe0f324959 Mon Sep 17 00:00:00 2001 From: Tyler Hobbs Date: Thu, 24 Apr 2014 14:04:48 -0500 Subject: [PATCH] Retry on received == required_responses in DCRP.on_read_timeout Fixes PYTHON-55 --- CHANGELOG.rst | 2 ++ cassandra/policies.py | 2 +- 2 files changed, 3 insertions(+), 1 deletion(-) diff --git a/CHANGELOG.rst b/CHANGELOG.rst index c53c6731..514019c1 100644 --- a/CHANGELOG.rst +++ b/CHANGELOG.rst @@ -10,6 +10,8 @@ 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 2d538c2d..bd41e253 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)