Honor the job_class for failed_queue.

8 years ago · 3cf5850afc
parent 89521f8dae
commit 3cf5850afc
1 changed files with 1 additions and 1 deletions
--- 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):