You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cassandra.apache.org by ca...@codespot.com on 2013/01/18 23:09:54 UTC

[cassandra-dbapi2] push by alek...@yeschenko.com - Fix tests on trunk on 2013-01-18 22:09 GMT

Revision: f04bf63edaa8
Author:   Aleksey Yeschenko <al...@yeschenko.com>
Date:     Fri Jan 18 14:08:17 2013
Log:      Fix tests on trunk

http://code.google.com/a/apache-extras.org/p/cassandra-dbapi2/source/detail?r=f04bf63edaa8

Modified:
  /cql/thrifteries.py

=======================================
--- /cql/thrifteries.py	Fri Jan 18 11:58:20 2013
+++ /cql/thrifteries.py	Fri Jan 18 14:08:17 2013
@@ -158,11 +158,12 @@

          self.remote_thrift_version = tuple(map(int,  
self.client.describe_version().split('.')))

-        if self.cql_version and self.remote_thrift_version <  
MIN_THRIFT_FOR_CL_IN_PROTOCOL:
+        if self.cql_version:
              self.set_cql_version(self.cql_version)

      def set_cql_version(self, cql_version):
-        self.client.set_cql_version(cql_version)
+        if self.remote_thrift_version < MIN_THRIFT_FOR_CL_IN_PROTOCOL:
+            self.client.set_cql_version(cql_version)
          try:
              self.cql_major_version = int(cql_version.split('.')[0])
          except ValueError: