job_scheduler.py 文件源码

def _start_step(self, job_id, **kwargs):
        with transaction.commit_on_success():
            result = StepResult(job_id=job_id, **kwargs)
            result.save()
        self._job_to_result[job_id] = result