diff --git a/server/lib/job-queue/job-queue.ts b/server/lib/job-queue/job-queue.ts index b0ccbd59c..66cced59a 100644 --- a/server/lib/job-queue/job-queue.ts +++ b/server/lib/job-queue/job-queue.ts @@ -1,5 +1,5 @@ import * as kue from 'kue' -import { JobType, JobState } from '../../../shared/models' +import { JobState, JobType } from '../../../shared/models' import { logger } from '../../helpers/logger' import { CONFIG, JOB_ATTEMPTS, JOB_COMPLETED_LIFETIME, JOB_CONCURRENCY } from '../../initializers' import { Redis } from '../redis' @@ -87,7 +87,7 @@ class JobQueue { }) } - async listForApi (state: JobState, start: number, count: number, sort: 'ASC' | 'DESC') { + async listForApi (state: JobState, start: number, count: number, sort: 'ASC' | 'DESC'): Promise { const jobStrings = await Redis.Instance.listJobs(this.jobRedisPrefix, state, 'alpha', sort, start, count) const jobPromises = jobStrings @@ -149,7 +149,7 @@ class JobQueue { } private getJob (id: number) { - return new Promise((res, rej) => { + return new Promise((res, rej) => { kue.Job.get(id, (err, job) => { if (err) return rej(err) diff --git a/server/lib/redis.ts b/server/lib/redis.ts index 2ecff939e..1fd366401 100644 --- a/server/lib/redis.ts +++ b/server/lib/redis.ts @@ -59,8 +59,6 @@ class Redis { this.client.sort(jobsPrefix + ':jobs:' + state, 'by', mode, order, 'LIMIT', offset.toString(), count.toString(), (err, values) => { if (err) return rej(err) - - return res(values) }) })