diff --git a/src/fenris/collector.py b/src/fenris/collector.py
index 40faac7..65e5a71 100644
--- a/src/fenris/collector.py
+++ b/src/fenris/collector.py
@@ -522,12 +522,10 @@ def run_collection(
         while True:
             conn.execute("BEGIN IMMEDIATE")
             waiting = _pending_count(conn)
-            if waiting >= PENDING_PUBLICATION_LIMIT:
-                conn.rollback()
-                published_count += _recover_pending_for_admission(conn)
-                checked_pending_count = _pending_count(conn)
-                continue
-            if waiting > checked_pending_count:
+            if (
+                waiting >= PENDING_PUBLICATION_LIMIT
+                or waiting > checked_pending_count
+            ):
                 conn.rollback()
                 published_count += _recover_pending_for_admission(conn)
                 checked_pending_count = _pending_count(conn)