def save_deferred(self, depends_on, pipe):
"""
Preparing job to defer (add as dependent). Works via pipeline.
Nothing done if WatchError happens while next `pipeline.execute()`.
"""
job = self.create_job(depends_on=depends_on, status=JobStatus.DEFERRED)
self.set_job_params(pipeline=pipe)
job.register_dependency(pipeline=pipe)
job.save(pipeline=pipe)
return job
评论列表
文章目录