Merge pull request binarymatt#121 from guilhermef/master

Registers worker again after a Redis flush

Author: binarymatt

pyres/worker.py

@@ -138,6 +138,8 @@ def work(self, interval=5):
                 logger.info('shutdown scheduled')
                 break
 
+            self.register_worker()
+
             job = self.reserve(interval)
 
             if job:

tests/test_worker.py

@@ -38,7 +38,7 @@ def test_unregister(self):
         assert self.redis.sismember('resque:workers',name)
         worker.unregister_worker()
         assert name not in self.redis.smembers('resque:workers')
-    
+
     def test_working_on(self):
         name = "%s:%s:%s" % (os.uname()[1],os.getpid(),'basic')
         self.resq.enqueue(Basic,"test1")