diff --git a/lib/queue.mjs b/lib/queue.mjs index d878c2a..381a4fa 100644 --- a/lib/queue.mjs +++ b/lib/queue.mjs @@ -98,6 +98,8 @@ export function updateJobStatus(id, status, extra = {}) { } export function addJobs(newJobs) { + // Always read fresh from disk to avoid clobbering concurrent writes (e.g. filter scoring) + _queueCache = null; const queue = loadQueue(); const existingIds = new Set(queue.map(j => j.id)); const existingUrls = new Set(queue.map(j => j.url));