feat(next/api): update failed export task

leancloud · Mar 26, 2024 · 323ac14 · 323ac14
1 parent 27dc154
commit 323ac14
Showing 1 changed file with 10 additions and 1 deletion.
diff --git a/next/api/src/ticket/export/index.ts b/next/api/src/ticket/export/index.ts
@@ -51,8 +51,17 @@ queue.on('completed', async (job, result) => {
   }
 });
 
-queue.on('failed', (job, err) => {
+queue.on('failed', async (job, err) => {
   console.error('[export ticket]:', job.data, err);
+  const task = await ExportTicketTask.find(job.data.taskId, { useMasterKey: true });
+  if (task) {
+    await task.update(
+      {
+        status: 'failed',
+      },
+      { useMasterKey: true }
+    );
+  }
 });
 
 export async function createTicketExportJob(jobData: Omit<JobData, 'date' | 'taskId'>) {