Ups concurrency (#104)

This commit is contained in:
Chris Anderson 2023-03-31 14:58:03 -05:00 committed by GitHub
parent f1aeb0c7c8
commit a273247809
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23

View file

@ -58,7 +58,7 @@ export default class RedisQueueProvider implements QueueProvider {
start(): void {
this.worker = new Worker('parcelvoy', async job => {
await this.queue.dequeue(job.data)
}, { connection: this.config })
}, { connection: this.config, concurrency: 25 })
this.worker.on('failed', (job, error) => {
logger.error({ error }, 'sqs:error:processing')
})