- createJob (obj: CreateJobArgument, priority = 'normal') {
- return new Promise((res, rej) => {
- this.jobQueue
- .create(obj.type, obj.payload)
- .priority(priority)
- .attempts(JOB_ATTEMPTS[obj.type])
- .backoff({ delay: 60 * 1000, type: 'exponential' })
- .save(err => {
- if (err) return rej(err)
-
- return res()
- })
- })