From 3e1ecc90e4f3090be1094e8a4e42ed118e8c2c96 Mon Sep 17 00:00:00 2001 From: xavierk Date: Mon, 28 Sep 2026 15:05:47 +0530 Subject: [PATCH] refactor: consolidate pending recovery checks (#101) --- src/fenris/collector.py | 10 ++++------ 1 file changed, 4 insertions(+), 6 deletions(-) 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)