This commit is contained in:
Boki 2025-06-11 11:11:47 -04:00
parent 07f8964a8c
commit d9bd33a822
4 changed files with 103 additions and 100 deletions

View file

@ -9,8 +9,8 @@ export class QueueService {
private queueEvents!: QueueEvents;
private config = {
workers: parseInt(process.env.WORKER_COUNT || '5'),
concurrency: parseInt(process.env.WORKER_CONCURRENCY || '20'),
workers: 1, //parseInt(process.env.WORKER_COUNT || '5'),
concurrency: 1, //parseInt(process.env.WORKER_CONCURRENCY || '20'),
redis: {
host: process.env.DRAGONFLY_HOST || 'localhost',
port: parseInt(process.env.DRAGONFLY_PORT || '6379'),
@ -45,7 +45,10 @@ export class QueueService {
removeOnComplete: 10,
removeOnFail: 5,
attempts: 3,
backoff: { type: 'exponential', delay: 1000 },
backoff: {
type: 'exponential',
delay: 1000,
},
},
});