feat(api): allow workflow trigger to specify a priority that's passed…

… onto bullmq
novuhq · Sep 18, 2024 · 1ec9489 · 1ec9489
1 parent 62f5211
commit 1ec9489
Show file tree

Hide file tree

Showing 2 changed files with 13 additions and 2 deletions.
diff --git a/apps/api/src/app/events/usecases/parse-event-request/parse-event-request.command.ts b/apps/api/src/app/events/usecases/parse-event-request/parse-event-request.command.ts
@@ -1,4 +1,4 @@
-import { IsDefined, IsString, IsOptional, ValidateNested, ValidateIf, IsEnum } from 'class-validator';
+import { IsDefined, IsString, IsOptional, ValidateNested, ValidateIf, IsEnum, IsNumber } from 'class-validator';
 import {
   AddressingTypeEnum,
   TriggerRecipients,
@@ -37,6 +37,10 @@ export class ParseEventRequestBaseCommand extends EnvironmentWithUserCommand {
   @IsOptional()
   @IsEnum(TriggerRequestCategoryEnum)
   requestCategory?: TriggerRequestCategoryEnum;
+
+  @IsOptional()
+  @IsNumber()
+  priority?: number;
 }
 
 export class ParseEventRequestMulticastCommand extends ParseEventRequestBaseCommand {

diff --git a/apps/api/src/app/events/usecases/parse-event-request/parse-event-request.usecase.ts b/apps/api/src/app/events/usecases/parse-event-request/parse-event-request.usecase.ts
@@ -137,7 +137,14 @@ export class ParseEventRequest {
       transactionId,
     };
 
-    await this.workflowQueueService.add({ name: transactionId, data: jobData, groupId: command.organizationId });
+    const options = process.env.IS_DOCKER_HOSTED === 'true' && command.priority ? { priority: command.priority } : {};
+
+    await this.workflowQueueService.add({
+      name: transactionId,
+      data: jobData,
+      groupId: command.organizationId,
+      ...options,
+    });
 
     return {
       acknowledged: true,