__init__.py 文件源码

def _add_checkpoint(self, id):
        self.job.checkpoint_archives.append(bin_to_hex(id))
        transaction.get().note('Added checkpoint archive %s for job %s' % (bin_to_hex(id), self.job.id))
        transaction.commit()