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.
2 parents a7750c5 + cbd5c78 commit ab41996Copy full SHA for ab41996
pyres/__init__.py
@@ -20,8 +20,10 @@ def str_to_class(s):
20
21
class ResQ(object):
22
23
- def __init__(self, server="localhost:6379"):
+ def __init__(self, server="localhost:6379", password=None):
24
self.redis = server
25
+ if password:
26
+ self.redis.auth(password)
27
self._watched_queues = set()
28
29
def push(self, queue, item):
pyres/worker.py
@@ -207,7 +207,7 @@ def working(cls, host):
207
for key in total:
208
value = resq.redis.get(key)
209
if value:
210
- w = Worker.find(key[7:], resq)
+ w = Worker.find(key[14:], resq) #resque:worker:
211
names.append(w)
212
return names
213
0 commit comments