Permalink
Browse files

Updated gworker.

  • Loading branch information...
1 parent f5f090f commit bcf094b4d32a5850bbf701f963acf5e0d9efa19f Dan Lecocq committed May 9, 2012
Showing with 4 additions and 0 deletions.
  1. +4 −0 qless/gworker.py
View
4 qless/gworker.py
@@ -9,6 +9,10 @@ def __init__(self, *args, **kwargs):
worker.Worker.__init__(self, *args, **kwargs)
def work(self):
+ # We should probably open up our own redis client
+ self.client = qless.client(self.host, self.port)
+ self.queues = [self.client.queues[q] for q in self.queues]
+
if not os.path.isdir(self.sandbox):
os.makedirs(self.sandbox)

0 comments on commit bcf094b

Please sign in to comment.