From 3de66b7e68902d1ee12c5b3429baa74d700b5c7f Mon Sep 17 00:00:00 2001 From: Nevo David Date: Thu, 13 Mar 2025 19:45:57 +0700 Subject: [PATCH] feat: fix scheduler --- libraries/nestjs-libraries/src/bull-mq-transport-new/client.ts | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/libraries/nestjs-libraries/src/bull-mq-transport-new/client.ts b/libraries/nestjs-libraries/src/bull-mq-transport-new/client.ts index 00d54911..0354b3f3 100644 --- a/libraries/nestjs-libraries/src/bull-mq-transport-new/client.ts +++ b/libraries/nestjs-libraries/src/bull-mq-transport-new/client.ts @@ -80,7 +80,7 @@ export class BullMqClient extends ClientProxy { async dispatchEvent(packet: ReadPacket): Promise { console.log('event to dispatch: ', packet); const queue = this.getQueue(packet.pattern); - if (packet.data.options.every) { + if (packet?.data?.options?.every) { const { every, immediately } = packet.data.options; const id = packet.data.id ?? v4(); await queue.upsertJobScheduler(