job_scheduler.py 文件源码

def _step_success(self, job_id, step_result):
        result = self._job_to_result[job_id]
        with transaction.commit_on_success():
            result.state = 'success'
            result.result = json.dumps(step_result)
            result.save()