Skip to content

Commit e8d70db

Browse files
committed
feat: add self-deletion for jobs
1 parent d2bf742 commit e8d70db

File tree

1 file changed

+2
-4
lines changed

1 file changed

+2
-4
lines changed

index.ts

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -426,7 +426,8 @@ export default class UploadPlugin extends AdminForthPlugin {
426426
jobs.set(jobId, { status: "in_progress" });
427427

428428
setTimeout(async () => await this.generateImages(jobId, prompt, recordId, adminUser, headers), 100);
429-
429+
setTimeout(() => jobs.delete(jobId), 300_000);
430+
430431
return { ok: true, jobId };
431432
}
432433
});
@@ -443,9 +444,6 @@ export default class UploadPlugin extends AdminForthPlugin {
443444
if (!job) {
444445
return { error: "Job not found" };
445446
}
446-
if (job.status === 'completed') {
447-
setTimeout(() => jobs.delete(jobId), 60_000);
448-
}
449447
return { ok: true, job };
450448
}
451449
});

0 commit comments

Comments
 (0)