error branch at worker.relay.

anselm/worker.py

@@ -71,7 +71,7 @@ class Worker(System):
             self.r.publish('io', line)
         else:
             self.log.error("... try again")
-            self.relay_worker(self, task, line)
+            self.relay_worker(task, line)
 
     def wait_worker(self, task, line):
         time.sleep(5)