()
| 97 | |
| 98 | let redisQueue: ExtendedRedis; |
| 99 | export function getRedisQueue() { |
| 100 | if (!redisQueue) { |
| 101 | // Use different redis for queues (self-hosting will re-use the same redis instance) |
| 102 | redisQueue = createRedisClient('redis-queue', REDIS_URL, { |
| 103 | ...options, |
| 104 | enableReadyCheck: false, |
| 105 | maxRetriesPerRequest: null, |
| 106 | enableOfflineQueue: true, |
| 107 | }); |
| 108 | } |
| 109 | |
| 110 | return redisQueue; |
| 111 | } |
| 112 | |
| 113 | let redisGroupQueue: ExtendedRedis; |
| 114 | export function getRedisGroupQueue() { |
no test coverage detected