test to provde owned() fails with decode_responses=True

1 files changed, 15 insertions, 3 deletions

diff --git a/tests/test_lock.py b/tests/test_lock.py
index 42dadef..f8218f6 100644
--- a/tests/test_lock.py
+++ b/tests/test_lock.py
@@ -2,10 +2,16 @@ import pytest
 import time
 
 from redis.exceptions import LockError, LockNotOwnedError
+from redis.client import Redis
 from redis.lock import Lock
+from .conftest import _get_client
 
 
 class TestLock(object):
+    @pytest.fixture()
+    def r_decoded(self, request):
+        return _get_client(Redis, request=request, decode_responses=True)
+
     def get_lock(self, redis, *args, **kwargs):
         kwargs['lock_class'] = Lock
         return redis.lock(*args, **kwargs)
@@ -36,15 +42,15 @@ class TestLock(object):
         lock.release()
         assert lock.locked() is False
 
-    def test_owned(self, r):
-        lock = self.get_lock(r, 'foo')
+    def _test_owned(self, client):
+        lock = self.get_lock(client, 'foo')
         assert lock.owned() is False
         lock.acquire(blocking=False)
         assert lock.owned() is True
         lock.release()
         assert lock.owned() is False
 
-        lock2 = self.get_lock(r, 'foo')
+        lock2 = self.get_lock(client, 'foo')
         assert lock.owned() is False
         assert lock2.owned() is False
         lock2.acquire(blocking=False)
@@ -54,6 +60,12 @@ class TestLock(object):
         assert lock.owned() is False
         assert lock2.owned() is False
 
+    def test_owned(self, r):
+        self._test_owned(r)
+
+    def test_owned_with_decoded_responses(self, r_decoded):
+        self._test_owned(r_decoded)
+
     def test_competing_locks(self, r):
         lock1 = self.get_lock(r, 'foo')
         lock2 = self.get_lock(r, 'foo')