fix queue collision

This commit is contained in:
smart_ex 2022-04-19 17:09:45 +10:00 committed by Danil Kovtonyuk
parent 76cda01ee1
commit 632dce129d
1 changed files with 3 additions and 1 deletions

View File

@ -1,9 +1,11 @@
const { v4: uuid } = require('uuid')
const Queue = require('bull')
const { netId } = require('./config')
const { status } = require('./constants')
const { redis, redisUrl } = require('./modules/redis')
const queue = new Queue('proofs', redisUrl, {
const queue = new Queue(`proofs_${netId}`, redisUrl, {
lockDuration: 300000, // Key expiration time for job locks.
lockRenewTime: 30000, // Interval on which to acquire the job lock
stalledInterval: 30000, // How often check for stalled jobs (use 0 for never checking).