From 60cfb7618e3b3dcf6d3568324f0ad4d1f03572b7 Mon Sep 17 00:00:00 2001 From: Celes Renata Date: Thu, 16 Apr 2026 18:27:21 +0000 Subject: [PATCH] =?UTF-8?q?fix:=20recovery=20sweep=20skips=20docs=20that?= =?UTF-8?q?=20already=20have=20global=5Fevents=20=E2=80=94=20prevents=20re?= =?UTF-8?q?-enqueue=20loop?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- services/scheduler/app.py | 3 +++ 1 file changed, 3 insertions(+) diff --git a/services/scheduler/app.py b/services/scheduler/app.py index 539d3f0..63c485b 100644 --- a/services/scheduler/app.py +++ b/services/scheduler/app.py @@ -522,6 +522,9 @@ async def recover_stale_documents(pool: asyncpg.Pool, rds: aioredis.Redis) -> in LEFT JOIN document_company_mentions dcm ON d.id = dcm.document_id WHERE d.status = 'parsed' AND d.updated_at < NOW() - INTERVAL '1 minute' * $1 + AND NOT EXISTS ( + SELECT 1 FROM global_events ge WHERE ge.source_document_id = d.id + ) ORDER BY d.created_at ASC LIMIT 100""", STALE_PARSED_THRESHOLD_MINUTES,