fix

twentyhq · Oct 16, 2024 · 68c8612 · 68c8612
1 parent 9112b6c
commit 68c8612
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 11 deletions.
diff --git a/packages/twenty-server/src/engine/core-modules/message-queue/drivers/bullmq.driver.ts b/packages/twenty-server/src/engine/core-modules/message-queue/drivers/bullmq.driver.ts
@@ -1,12 +1,6 @@
 import { OnModuleDestroy } from '@nestjs/common';
 
-import {
-  ConnectionOptions,
-  JobsOptions,
-  Queue,
-  QueueOptions,
-  Worker,
-} from 'bullmq';
+import { JobsOptions, Queue, QueueOptions, Worker } from 'bullmq';
 import omitBy from 'lodash.omitby';
 
 import {
@@ -19,9 +13,7 @@ import { MessageQueueWorkerOptions } from 'src/engine/core-modules/message-queue
 
 import { MessageQueue } from 'src/engine/core-modules/message-queue/message-queue.constants';
 
-export type BullMQDriverOptions = QueueOptions & {
-  connection?: ConnectionOptions | string;
-};
+export type BullMQDriverOptions = QueueOptions;
 
 export class BullMQDriver implements MessageQueueDriver, OnModuleDestroy {
   private queueMap: Record<MessageQueue, Queue> = {} as Record<

diff --git a/packages/twenty-server/src/engine/core-modules/message-queue/message-queue.module-factory.ts b/packages/twenty-server/src/engine/core-modules/message-queue/message-queue.module-factory.ts
@@ -1,3 +1,5 @@
+import { ConnectionOptions } from 'tls';
+
 import { EnvironmentService } from 'src/engine/core-modules/environment/environment.service';
 import {
   BullMQDriverFactoryOptions,
@@ -46,7 +48,7 @@ export const messageQueueModuleFactory = async (
       return {
         type: MessageQueueDriverType.BullMQ,
         options: {
-          connection: connectionString,
+          connection: connectionString as ConnectionOptions,
         },
       } satisfies BullMQDriverFactoryOptions;
     }