set process jobName required

twentyhq · Jun 14, 2024 · cc84a97 · cc84a97
1 parent 5e38924
commit cc84a97
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/packages/twenty-server/src/engine/integrations/message-queue/decorators/process.decorator.ts b/packages/twenty-server/src/engine/integrations/message-queue/decorators/process.decorator.ts
@@ -4,7 +4,7 @@ import { isString } from '@nestjs/common/utils/shared.utils';
 import { PROCESS_METADATA } from 'src/engine/integrations/message-queue/message-queue.constants';
 
 export interface MessageQueueProcessOptions {
-  jobName?: string;
+  jobName: string;
   concurrency?: number;
 }
 

diff --git a/packages/twenty-server/src/engine/integrations/message-queue/message-queue.explorer.ts b/packages/twenty-server/src/engine/integrations/message-queue/message-queue.explorer.ts
@@ -194,7 +194,7 @@ export class MessageQueueExplorer implements OnModuleInit {
     job: MessageQueueJob<MessageQueueJobData>,
   ) {
     for (const [methodName, metadata] of processMetadataCollection) {
-      if (job.name === metadata?.jobName || !metadata?.jobName) {
+      if (job.name === metadata?.jobName) {
         try {
           await instance[methodName].call(instance, job.data);
         } catch (err) {