Fix filtered queue processing.

reddit-archive · Apr 26, 2012 · 319247d · 319247d
1 parent 704a464
commit 319247d
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/postcards/lib/queue.py b/postcards/lib/queue.py
@@ -36,10 +36,10 @@ def handle_queued_jobs(filter=None):
     while True:
         try:
             query = (QueuedJob.query.filter(QueuedJob.id > last_id)
-                                    .order_by(db.asc(QueuedJob.id))
-                                    .limit(1))
+                                    .order_by(db.asc(QueuedJob.id)))
             if filter:
                 query = query.filter(QueuedJob.handler == filter)
+            query = query.limit(1)
             job = query.one()
         except sqlalchemy.orm.exc.NoResultFound:
             break

diff --git a/process_queue.py b/process_queue.py
@@ -12,4 +12,4 @@
 elif len(sys.argv) == 2:
     filter = sys.argv[1]
 
-handle_queued_jobs()
+handle_queued_jobs(filter)