diff --git a/lib/extract.py b/lib/extract.py
index 1da8515..378cd11 100644
--- a/lib/extract.py
+++ b/lib/extract.py
@@ -743,8 +743,8 @@ async def extract_cycle(conn, max_workers=None) -> tuple[int, int]:
         except Exception:
             logger.debug("Failed to read source %s", f, exc_info=True)
 
-    if not unprocessed:
-        return 0, 0
+    # Don't early-return here — re-extraction sources may exist even when queue is empty
+    # (the re-extraction check runs after open-PR filtering below)
 
     # Filter out sources that already have open extraction PRs
     open_pr_slugs = set()