From d46ad2dbf0900aba7f8ac4e33954c1a04d953d0f Mon Sep 17 00:00:00 2001 From: NgoQuocViet2001 Date: Fri, 14 Aug 2026 15:14:03 +0700 Subject: [PATCH] fix(downloads): guard orphaned model jobs --- admin/app/services/download_service.ts | 7 +++---- 1 file changed, 3 insertions(+), 4 deletions(-) diff --git a/admin/app/services/download_service.ts b/admin/app/services/download_service.ts index 7af5919..d61908a 100644 --- a/admin/app/services/download_service.ts +++ b/admin/app/services/download_service.ts @@ -56,11 +56,10 @@ export class DownloadService { } async listDownloadJobs(filetype?: string): Promise { - const modelQueue = this.queueService.getQueue(DownloadModelJob.queue) - const [fileTagged, extractTagged, modelJobs, drugTagged] = await Promise.all([ + const [fileTagged, extractTagged, modelTagged, drugTagged] = await Promise.all([ this.fetchJobsWithStates(RunDownloadJob.queue), this.fetchJobsWithStates(RunExtractPmtilesJob.queue), - modelQueue.getJobs(['waiting', 'active', 'delayed', 'failed']), + this.fetchJobsWithStates(DownloadModelJob.queue), this.fetchJobsWithStates(DownloadDrugDataJob.queue), ]) @@ -98,7 +97,7 @@ export class DownloadService { } }) - const modelDownloads = modelJobs.map((job) => ({ + const modelDownloads = modelTagged.map(({ job }) => ({ jobId: job.id!.toString(), url: job.data.modelName || 'Unknown Model', progress: parseInt(job.progress.toString(), 10),