Skip to content

Commit 69f82d2

Browse files
author
Matt George
committed
Merge branch 'bug/disconnect' into release/1.0.1
2 parents fe9aa2a + 8d25c03 commit 69f82d2

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)