feat: add support for prioritized jobs

s-r-x · Aug 1, 2023 · 1092d9a · 1092d9a
1 parent c6b6c58
commit 1092d9a
Show file tree

Hide file tree

Showing 21 changed files with 453 additions and 123 deletions.
diff --git a/fixtures/bull-server/server/index.ts b/fixtures/bull-server/server/index.ts
@@ -6,7 +6,6 @@ import Queue from 'bull';
 import {
   Queue as BullMqQueue,
   Worker as MqWorker,
-  QueueScheduler as MqQueueScheduler,
   ConnectionOptions,
 } from 'bullmq';
 
@@ -47,9 +46,6 @@ const mqQueues = [
     connection: mqConnOptions,
   }),
 ];
-new MqQueueScheduler(mqQueues[0].name, {
-  connection: mqConnOptions,
-});
 mqQueues.forEach((queue) => {
   new MqWorker(
     queue.name,