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