def get_jobs(self, worker=None): deferred = self.remoteobj.callRemote('get_job', 1) deferred.addCallback(self._got_job, self.workers[0]) deferred.addCallback(self.submit_job) deferred.addCallback(self.get_jobs) deferred.addErrback(self._catch_failure)