From 10070c1752b5efcbfdf351454de06fbbbe9fb0b6 Mon Sep 17 00:00:00 2001 From: Mohamed Bassem Date: Sat, 9 Nov 2024 13:35:28 +0000 Subject: fix: Feed refreshes were not getting re-enqueued for failed jobs --- packages/shared/package.json | 2 +- packages/shared/queues.ts | 6 ++++++ 2 files changed, 7 insertions(+), 1 deletion(-) (limited to 'packages/shared') diff --git a/packages/shared/package.json b/packages/shared/package.json index 32ffa737..d741b70f 100644 --- a/packages/shared/package.json +++ b/packages/shared/package.json @@ -6,7 +6,7 @@ "type": "module", "dependencies": { "glob": "^11.0.0", - "liteque": "^0.2.0", + "liteque": "^0.3.0", "meilisearch": "^0.37.0", "ollama": "^0.5.9", "openai": "^4.67.1", diff --git a/packages/shared/queues.ts b/packages/shared/queues.ts index 7baae535..a887417d 100644 --- a/packages/shared/queues.ts +++ b/packages/shared/queues.ts @@ -27,6 +27,7 @@ export const LinkCrawlerQueue = new SqliteQueue( defaultJobArgs: { numRetries: 5, }, + keepFailedJobs: false, }, ); @@ -43,6 +44,7 @@ export const OpenAIQueue = new SqliteQueue( defaultJobArgs: { numRetries: 3, }, + keepFailedJobs: false, }, ); @@ -61,6 +63,7 @@ export const SearchIndexingQueue = new SqliteQueue( defaultJobArgs: { numRetries: 5, }, + keepFailedJobs: false, }, ); @@ -77,6 +80,7 @@ export const TidyAssetsQueue = new SqliteQueue( defaultJobArgs: { numRetries: 1, }, + keepFailedJobs: false, }, ); @@ -107,6 +111,7 @@ export const VideoWorkerQueue = new SqliteQueue( defaultJobArgs: { numRetries: 5, }, + keepFailedJobs: false, }, ); @@ -131,5 +136,6 @@ export const FeedQueue = new SqliteQueue( // One retry is enough for the feed queue given that it's periodic numRetries: 1, }, + keepFailedJobs: false, }, ); -- cgit v1.2.3-70-g09d2