Update JobsUnit to pass IORedis config directly

master
Garrett Mills 2 years ago
parent 34d84120e8
commit b2eee3e5aa

@ -97,10 +97,7 @@ class JobsUnit extends CanonicalUnit {
for ( const queue_name of config.queues ) {
this.output.debug(`Connecting to job queue ${queue_name}...`)
this.#queues[queue_name] = new Queue(queue_name, {
connection: {
host: redis_config.server.host,
port: redis_config.server.port,
}
connection: redis_config.server,
})
}
}

Loading…
Cancel
Save