this.jobRedisPrefix = 'bull-' + CONFIG.WEBSERVER.HOST
const queueOptions = {
prefix: this.jobRedisPrefix,
- redis: Redis.getRedisClient()
+ redis: Redis.getRedisClient(),
+ settings: {
+ maxStalledCount: 10 // transcoding could be long, so jobs can often be interrupted by restarts
+ }
}
for (const handlerName of Object.keys(handlers)) {
}
}
+ terminate () {
+ for (const queueName of Object.keys(this.queues)) {
+ const queue = this.queues[queueName]
+ queue.close()
+ }
+ }
+
createJob (obj: CreateJobArgument) {
const queue = this.queues[obj.type]
if (queue === undefined) {