Don't retry on IRE or ITR

driftx · Feb 27, 2010 · f6e39f5 · f6e39f5
1 parent 0f1596f
commit f6e39f5
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/telephus/protocol.py b/telephus/protocol.py
@@ -4,6 +4,7 @@
 from twisted.internet import defer, reactor
 from twisted.internet.error import UserError
 from telephus.cassandra import Cassandra
+from telephus.cassandra.ttypes import InvalidRequestException
 
 class ClientBusy(Exception):
     pass
@@ -96,7 +97,8 @@ def clientGone(self, proto):
     @defer.inlineCallbacks
     def submitRequest(self, proto):
         def reqError(err, req, d, r):
-            if r < 1:
+            if isinstance(err, InvalidRequestException) or \
+               isinstance(err, InvalidThriftRequest) or r < 1:
                 d.errback(err)
                 self._pending.remove(d)
             else: