From da8b2d3b4d4046dcbb9105f7cb7e671f0a3e6fa8 Mon Sep 17 00:00:00 2001 From: alikia2x Date: Sun, 30 Mar 2025 20:48:40 +0800 Subject: [PATCH] fix: timeout interva ltoo short in cleanup --- packages/crawler/mq/exec/snapshotTick.ts | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/packages/crawler/mq/exec/snapshotTick.ts b/packages/crawler/mq/exec/snapshotTick.ts index defe21a..abec4f6 100644 --- a/packages/crawler/mq/exec/snapshotTick.ts +++ b/packages/crawler/mq/exec/snapshotTick.ts @@ -371,8 +371,8 @@ export const scheduleCleanupWorker = async (_job: Job) => { const query = ` SELECT id, aid, type FROM snapshot_schedule - WHERE status IN ('pending', 'processing') - AND started_at < NOW() - INTERVAL '5 minutes' + WHERE status IN ('pending', 'processing') + AND started_at < NOW() - INTERVAL '30 minutes' `; const { rows } = await client.queryObject<{ id: bigint; aid: bigint; type: string }>(query); if (rows.length === 0) return;