fix: support for older BullMQ versions, round 2

felixmosh · Nov 15, 2024 · 1634438 · 1634438
1 parent c72b28c
commit 1634438
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/packages/api/src/queueAdapters/bullMQ.ts b/packages/api/src/queueAdapters/bullMQ.ts
@@ -14,7 +14,9 @@ export class BullMQAdapter extends BaseAdapter {
   constructor(private queue: Queue, options: Partial<QueueAdapterOptions> = {}) {
     const libName = 'bullmq';
     super(libName, options);
-    if (!(queue instanceof Queue) || !(queue.metaValues?.version as string)?.startsWith(libName)) {
+    if (
+      !(queue instanceof Queue || `${(queue as Queue).metaValues?.version}`?.startsWith(libName))
+    ) {
       throw new Error(`You've used the BullMQ adapter with a non-BullMQ queue.`);
     }
   }