diff --git a/packages/api/src/jobs/rss/refreshAllFeeds.ts b/packages/api/src/jobs/rss/refreshAllFeeds.ts index ef49bacac..8f0f69ad1 100644 --- a/packages/api/src/jobs/rss/refreshAllFeeds.ts +++ b/packages/api/src/jobs/rss/refreshAllFeeds.ts @@ -138,5 +138,7 @@ export const queueRSSRefreshFeedJob = async ( return queue.add('refresh-feed', payload, { jobId: jobid, priority: options.priority == 'low' ? 10 : 50, + removeOnComplete: true, + removeOnFail: true, }) } diff --git a/packages/api/src/utils/createTask.ts b/packages/api/src/utils/createTask.ts index 3f9a6b70b..27d3ec3ee 100644 --- a/packages/api/src/utils/createTask.ts +++ b/packages/api/src/utils/createTask.ts @@ -694,6 +694,8 @@ export const bulkEnqueueUpdateLabels = async (data: UpdateLabelsData[]) => { jobId: `${UPDATE_LABELS_JOB}_${d.libraryItemId}`, attempts: 6, priority: 1, + removeOnComplete: true, + removeOnFail: true, }, })) @@ -716,6 +718,8 @@ export const enqueueUpdateHighlight = async (data: UpdateHighlightData) => { jobId: `${UPDATE_HIGHLIGHT_JOB}_${data.libraryItemId}`, attempts: 6, priority: 1, + removeOnComplete: true, + removeOnFail: true, }) } catch (error) { logger.error('error enqueuing update highlight job', error) @@ -735,6 +739,8 @@ export const enqueueBulkAction = async (data: BulkActionData) => { attempts: 1, priority: 10, jobId, // deduplication + removeOnComplete: true, + removeOnFail: true, }) } catch (error) { logger.error('error enqueuing bulk action job', error)