Log entire message on failure to decode

2014-04-23 16:02:49 -05:00
parent d1a72e8e86
commit 061991f2a3
1 changed files with 1 additions and 1 deletions
--- a/cassandra/connection.py
+++ b/cassandra/connection.py
@@ -302,7 +302,7 @@ class Connection(object):
            response = decode_response(stream_id, flags, opcode, body, self.decompressor)
        except Exception as exc:
            log.exception("Error decoding response from Cassandra. "
-                          "opcode: %04x; message contents: %r", opcode, body)
+                          "opcode: %04x; message contents: %r", opcode, msg)
            if callback is not None:
                callback(exc)
            self.defunct(exc)