Skip to content

Commit 8d25c03

Browse files
author
Matt George
committed
fixing bug with old redis-py api call
1 parent fe9aa2a commit 8d25c03

File tree

2 files changed

+5
-2
lines changed

2 files changed

+5
-2
lines changed

pyres/__init__.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -226,7 +226,7 @@ def close(self):
226226
"""Close the underlying redis connection.
227227
228228
"""
229-
self.redis.disconnect()
229+
self.redis.connection.disconnect()
230230

231231
def enqueue_at(self, datetime, klass, *args, **kwargs):
232232
class_name = '%s.%s' % (klass.__module__, klass.__name__)

tests/test_resq.py

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -99,4 +99,7 @@ def test_queues(self):
9999
self.resq.enqueue_from_string('tests.Basic','basic2','test1')
100100
assert len(self.resq.queues()) == 2
101101
assert 'test' not in self.resq.queues()
102-
assert 'basic' in self.resq.queues()
102+
assert 'basic' in self.resq.queues()
103+
104+
def test_close(self):
105+
self.resq.close()

0 commit comments

Comments
 (0)