From 415a159ac3b41c98c288d306f64f8d98be275de1 Mon Sep 17 00:00:00 2001 From: Jonas Date: Fri, 8 Jun 2012 15:20:05 +0200 Subject: [PATCH] Pass connection explicitly to Job.fetch --- rq/queue.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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: