diff --git a/rq/queue.py b/rq/queue.py index 3872a20..0f07139 100644 --- 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: