chore: Update BullMQ version to 3.0.0

2022-10-30 18:52:53 +01:00
parent e58b7166ad
commit 6964f7ebec
3 changed files with 144 additions and 69 deletions
--- a/packages/backend/src/queues/flow.ts
+++ b/packages/backend/src/queues/flow.ts
@@ -1,5 +1,5 @@
 import process from 'process';
-import { Queue, QueueScheduler } from 'bullmq';
+import { Queue } from 'bullmq';
 import redisConfig from '../config/redis';
 import logger from '../helpers/logger';

@@ -10,10 +10,9 @@ const redisConnection = {
 };

 const flowQueue = new Queue('flow', redisConnection);
-const queueScheduler = new QueueScheduler('flow', redisConnection);

 process.on('SIGTERM', async () => {
-  await queueScheduler.close();
+  await flowQueue.close();
 });

 flowQueue.on('error', (err) => {