fix kick for tarantool 1.6

igorcoding · Oct 25, 2017 · 5b0601b · 5b0601b
1 parent 77d292b
commit 5b0601b
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 0 deletions.
diff --git a/.ci/travis-before-install.sh b/.ci/travis-before-install.sh
@@ -17,6 +17,7 @@ if [[ "${TRAVIS_OS_NAME}" == "linux" ]]; then
     sudo luarocks install https://raw.githubusercontent.com/tarantool/rocks/gh-pages/queue-scm-1.rockspec
 
 elif [[ "${TRAVIS_OS_NAME}" == "osx" ]]; then
+    brew update
     if [[ "${TARANTOOL_VERSION}" == "1_7" ]]; then
         brew install tarantool --HEAD
     else

diff --git a/asynctnt_queue/tube.py b/asynctnt_queue/tube.py
@@ -196,6 +196,8 @@ async def kick(self, count):
         """
         args = (count,)
         res = await self.conn.call(self.__funcs['kick'], args)
+        if self.conn.version < (1, 7):
+            return res.body[0][0]
         return res.body[0]
 
     def statistics(self):