Merge pull request #83 from jonasvp/master

safe_fetch() didn't pass connection to Job.fetch() Thanks @jonasvp!
13 years ago · 5c11ea6296
parent 074d42fe54 415a159ac3
commit 5c11ea6296
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: