Pass connection explicitly to Job.fetch

13 years ago · 415a159ac3
parent 074d42fe54
commit 415a159ac3
1 changed files with 1 additions and 1 deletions
--- a/rq/queue.py
+++ b/rq/queue.py
@ -74,7 +74,7 @@ class Queue(object):
        """Returns a list of all (valid) jobs in the queue."""
        def safe_fetch(job_id):
            try:
-                job = Job.fetch(job_id)
+                job = Job.fetch(job_id, connection=self.connection)
            except NoSuchJobError:
                return None
            except UnpickleError: