Reset run and requeue pipeline for execution.
(self)
| 2254 | dequeue_job(self.run_id) |
| 2255 | |
| 2256 | def requeue(self): |
| 2257 | """Reset run and requeue pipeline for execution.""" |
| 2258 | if job := self.job: |
| 2259 | self.reset_run() |
| 2260 | return job.requeue() |
| 2261 | |
| 2262 | |
| 2263 | class PipelineSchedule(models.Model): |