diff options
| author | Steve Kreitzer <skre@skre.me> | 2022-05-22 00:56:14 -0500 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2022-05-22 12:56:14 +0700 |
| commit | ecf0d06090f8899187e42cb4f49e0f239345df2f (patch) | |
| tree | bdc9c65e292c05c87963d4ddac221b89f2bd0f74 | |
| parent | 48df759879198d9c69711d6af2731065e4f5fdef (diff) | |
| download | rq-ecf0d06090f8899187e42cb4f49e0f239345df2f.tar.gz | |
Support at_front requeue support (#1657)
Co-authored-by: Steve Kreitzer <skreitzer@cloudflare.com>
| -rw-r--r-- | rq/job.py | 4 | ||||
| -rw-r--r-- | rq/registry.py | 4 |
2 files changed, 4 insertions, 4 deletions
@@ -734,9 +734,9 @@ class Job: # handle it raise - def requeue(self): + def requeue(self, at_front=False): """Requeues job.""" - return self.failed_job_registry.requeue(self) + return self.failed_job_registry.requeue(self, at_front=at_front) def _remove_from_registries(self, pipeline=None, remove_from_queue=True): if remove_from_queue: diff --git a/rq/registry.py b/rq/registry.py index e9652ad..089a787 100644 --- a/rq/registry.py +++ b/rq/registry.py @@ -110,7 +110,7 @@ class BaseRegistry: score = self.connection.zscore(self.key, job.id) return datetime.utcfromtimestamp(score) - def requeue(self, job_or_id): + def requeue(self, job_or_id, at_front=False): """Requeues the job with the given job ID.""" if isinstance(job_or_id, self.job_class): job = job_or_id @@ -130,7 +130,7 @@ class BaseRegistry: job.ended_at = None job.exc_info = '' job.save() - job = queue.enqueue_job(job, pipeline=pipeline) + job = queue.enqueue_job(job, pipeline=pipeline, at_front=at_front) pipeline.execute() return job |