Empty the queue before deleteing the jobs, in case new jobs arrive

rq/queue.py

@@ -65,9 +65,10 @@ class Queue(object):
 
     def empty(self):
         """Removes all messages on the queue."""
-        for job in self.get_jobs():
+        job_list = self.get_jobs()
-            job.cancel()
         self.connection.delete(self.key)
+        for job in job_list:
+            job.cancel()
 
     def is_empty(self):
         """Returns whether the current queue is empty."""