root/sp
1
0
Fork 0
Code Issues Pull Requests 2 Actions Packages Projects Releases Wiki Activity

fix(phase6a): increase BullMQ lockDuration to 5min (network/db calls exceed 30s)

Browse Source 
Co-Authored-By: Claude Opus 4.7 <noreply@anthropic.com>
This commit is contained in:
Semih
2026-05-13 21:15:06 +00:00
parent 1a7a1b5787
commit 795528982e
1 changed files with 6 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
apps/worker/src/schedulers/pipeline.ts
View File

@@ -49,6 +49,11 @@ export async function startInsightPipeline() {
{ name: "compress-sessions", data: {}, opts: { removeOnComplete: 50, removeOnFail: 25 } }, { name: "compress-sessions", data: {}, opts: { removeOnComplete: 50, removeOnFail: 25 } },
); );
new Worker(QUEUE, runJob, { connection: redis, concurrency: 2 }); new Worker(QUEUE, runJob, {
connection: redis,
concurrency: 2,
lockDuration: 5 * 60_000,
stalledInterval: 60_000,
});
console.log("[pipeline] armed: posthog-ingest@*/5min, tag-sessions@*/2min, compress-sessions@*/3min"); console.log("[pipeline] armed: posthog-ingest@*/5min, tag-sessions@*/2min, compress-sessions@*/3min");
} }