From 2eedba1522fce7ee4f31675cf984d9147d5df104 Mon Sep 17 00:00:00 2001 From: Hongbo Wu Date: Tue, 30 Jan 2024 18:14:34 +0800 Subject: [PATCH 1/2] fix: assign the rule job with priority 1 and do not retry --- packages/api/src/utils/createTask.ts | 2 ++ 1 file changed, 2 insertions(+) diff --git a/packages/api/src/utils/createTask.ts b/packages/api/src/utils/createTask.ts index 4e3ed31ce..c7e4cd5cd 100644 --- a/packages/api/src/utils/createTask.ts +++ b/packages/api/src/utils/createTask.ts @@ -655,6 +655,8 @@ export const enqueueTriggerRuleJob = async (data: TriggerRuleJobData) => { } return queue.add(TRIGGER_RULE_JOB_NAME, data, { + priority: 1, + attempts: 1, removeOnComplete: true, removeOnFail: true, }) From 36d2c21466e3b122768c677e421cc9590db6e6e6 Mon Sep 17 00:00:00 2001 From: Hongbo Wu Date: Tue, 30 Jan 2024 18:24:48 +0800 Subject: [PATCH 2/2] remove thumbnail job on complete or failure --- packages/api/src/utils/createTask.ts | 1 + 1 file changed, 1 insertion(+) diff --git a/packages/api/src/utils/createTask.ts b/packages/api/src/utils/createTask.ts index c7e4cd5cd..bc3d89f94 100644 --- a/packages/api/src/utils/createTask.ts +++ b/packages/api/src/utils/createTask.ts @@ -594,6 +594,7 @@ export const enqueueThumbnailJob = async ( return queue.add(THUMBNAIL_JOB, payload, { priority: 100, attempts: 1, + removeOnComplete: true, }) }