job_scheduler.py 文件源码

def _step_failure(self, job_id, backtrace):
        result = self._job_to_result[job_id]
        with transaction.commit_on_success():
            result.state = 'failed'
            result.backtrace = backtrace
            result.save()