job_scheduler.py 文件源码

def _console(self, job_id, log_string):
        result = self._job_to_result[job_id]
        with transaction.commit_on_success():
            result.console += log_string
            result.save()