that way I can put all the logging code and error checking code
in one place, and I don't have to pass around the client connection.
self.send(u, 'run %s finished' % (runDir))
if self.notify_runner is not None:
for r in self.notify_runner:
- rpc.send(self.cl, self.runner, (runDir,), 'runFinished')
+ self.rpc_send(self.runner, (runDir,), 'runFinished')
logging.info("forwarding runFinshed message for %s" % (runDir))
def update(self, *args):