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 edd5b5d commit 00214e3Copy full SHA for 00214e3
src/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