We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 1e2bf45 commit e74b0f6Copy full SHA for e74b0f6
pyres/__init__.py
@@ -140,9 +140,8 @@ class ResQ(object):
140
141
"""
142
def __init__(self, server="localhost:6379", password=None):
143
+ self.password = password
144
self.redis = server
- if password:
145
- self.redis.auth(password)
146
self._watched_queues = set()
147
148
def push(self, queue, item):
@@ -187,7 +186,7 @@ def _set_redis(self, server):
187
186
if isinstance(server, basestring):
188
self.dsn = server
189
host, port = server.split(':')
190
- self._redis = Redis(host=host, port=int(port))
+ self._redis = Redis(host=host, port=int(port), password=self.password)
191
self.host = host
192
self.port = int(port)
193
elif isinstance(server, Redis):
0 commit comments