extract safe_fetch_job method

rq/queue.py

@@ -64,6 +64,16 @@ def is_empty(self):
         """Returns whether the current queue is empty."""
         return self.count == 0
 
+    def safe_fetch_job(self, job_id):
+        try:
+            job = Job.safe_fetch(job_id, connection=self.connection)
+        except NoSuchJobError:
+            self.remove(job_id)
+            return None
+        except UnpickleError:
+            return None
+        return job
+
     @property
     def job_ids(self):
         """Returns a list of all job IDS in the queue."""
@@ -72,17 +82,7 @@ def job_ids(self):
     @property
     def jobs(self):
         """Returns a list of all (valid) jobs in the queue."""
-        def safe_fetch(job_id):
-            try:
-                job = Job.safe_fetch(job_id, connection=self.connection)
-            except NoSuchJobError:
-                self.remove(job_id)
-                return None
-            except UnpickleError:
-                return None
-            return job
-
-        return compact([safe_fetch(job_id) for job_id in self.job_ids])
+        return compact([self.safe_fetch_job(job_id) for job_id in self.job_ids])
 
     @property
     def count(self):