def on_job_exception(self, current_job, exc_info):
    self.send_job_failure(current_job)
    return False
def on_job_exception(self, current_job, exc_info):
    self.send_job_failure(current_job)
    return False