def handle_exception(self, job, *exc_info): log.exception(u'Job {} on worker {} raised an exception: {}'.format( job.id, self.key, exc_info[1])) return super(Worker, self).handle_exception(job, *exc_info)