diff options
Diffstat (limited to 'rq/registry.py')
| -rw-r--r-- | rq/registry.py | 4 |
1 files changed, 2 insertions, 2 deletions
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 |