Skip to content

Commit 87161c2

Browse files
committed
fixing bad connection call
1 parent 9dd846f commit 87161c2

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

pyres/__init__.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -279,7 +279,7 @@ def close(self):
279279
"""Close the underlying redis connection.
280280
281281
"""
282-
self.redis.connection.disconnect()
282+
self.redis.connection_pool.get_connection('_').disconnect()
283283

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

0 commit comments

Comments
 (0)