diff --git a/server/core/lib/job-queue/job-queue.ts b/server/core/lib/job-queue/job-queue.ts index 0f642446b..7922a830b 100644 --- a/server/core/lib/job-queue/job-queue.ts +++ b/server/core/lib/job-queue/job-queue.ts @@ -418,7 +418,11 @@ class JobQueue { continue } - const jobs = await queue.getJobs(states, 0, start + count, asc) + let jobs = await queue.getJobs(states, 0, start + count, asc) + + // FIXME: we have sometimes undefined values https://github.com/taskforcesh/bullmq/issues/248 + jobs = jobs.filter(j => !!j) + results = results.concat(jobs) }