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):