From 3cf5850afc5281cc27a5554c43f9b270b2fdd32b Mon Sep 17 00:00:00 2001 From: Amjith Ramanujam Date: Wed, 7 Jun 2017 13:31:44 -0700 Subject: [PATCH] Honor the job_class for failed_queue. --- rq/queue.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/rq/queue.py b/rq/queue.py index 06998d9..cbef351 100644 --- a/rq/queue.py +++ b/rq/queue.py @@ -115,7 +115,7 @@ class Queue(object): except NoSuchJobError: self.remove(job_id) else: - if job.origin == self.name or (job.is_failed and self == get_failed_queue(connection=self.connection)): + if job.origin == self.name or (job.is_failed and self == get_failed_queue(connection=self.connection, job_class=self.job_class)): return job def get_job_ids(self, offset=0, length=-1):