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 f1bad4a + 00214e3 commit 3759f82Copy full SHA for 3759f82
pyres/worker.py
@@ -8,14 +8,14 @@
8
import simplejson
9
10
class Worker(object):
11
- def __init__(self, queues=[], server="localhost:6379"):
+ def __init__(self, queues=[], server="localhost:6379", password=None):
12
self.queues = queues
13
self.validate_queues()
14
self._shutdown = False
15
self.child = None
16
self.pid = os.getpid()
17
if isinstance(server,basestring):
18
- self.resq = ResQ(server)
+ self.resq = ResQ(server=server, password=password)
19
elif isinstance(server, ResQ):
20
self.resq = server
21
else:
0 commit comments