fix: dedupe update-db job by using library_item_id as job_id

2024-02-01 18:11:47 +08:00
parent 87928a517a
commit a939180dc9
1 changed files with 2 additions and 0 deletions
--- a/packages/api/src/utils/createTask.ts
+++ b/packages/api/src/utils/createTask.ts
@ -695,6 +695,7 @@ export const bulkEnqueueUpdateLabels = async (data: UpdateLabelsData[]) => {
    name: UPDATE_LABELS_JOB,
    data: d,
    opts: {
+      jobId: `${UPDATE_LABELS_JOB}_${d.libraryItemId}`,
      attempts: 6,
      priority: 1,
      backoff: {
@ -720,6 +721,7 @@ export const enqueueUpdateHighlight = async (data: UpdateHighlightData) => {

  try {
    return queue.add(UPDATE_HIGHLIGHT_JOB, data, {
+      jobId: `${UPDATE_HIGHLIGHT_JOB}_${data.libraryItemId}`,
      attempts: 6,
      priority: 1,
      backoff: {