We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 604b691 commit d1967dbCopy full SHA for d1967db
1 file changed
cassandra/policies.py
@@ -17,7 +17,7 @@
17
from random import randint
18
from threading import Lock
19
20
-from cassandra import ConsistencyLevel
+from cassandra import ConsistencyLevel, OperationTimedOut
21
22
log = logging.getLogger(__name__)
23
@@ -465,7 +465,7 @@ class SimpleConvictionPolicy(ConvictionPolicy):
465
"""
466
467
def add_failure(self, connection_exc):
468
- return True
+ return not isinstance(connection_exc, OperationTimedOut)
469
470
def reset(self):
471
pass
0 commit comments