From 09d06fbf6014df8733ea8dcf6dd7ff709bacfa14 Mon Sep 17 00:00:00 2001
From: Cursor Agent <cursoragent@cursor.com>
Date: Fri, 29 May 2026 15:08:21 +0000
Subject: [PATCH] refactor(worker): remove organization existence check from
 workflow worker

Co-authored-by: Dima Grossman <dima@grossman.io>
---
 .../workflow/services/workflow.worker.spec.ts   |  2 --
 .../app/workflow/services/workflow.worker.ts    | 17 -----------------
 2 files changed, 19 deletions(-)

diff --git a/apps/worker/src/app/workflow/services/workflow.worker.spec.ts b/apps/worker/src/app/workflow/services/workflow.worker.spec.ts
index 9f5d44e5d25..a3d67dc4e47 100644
--- a/apps/worker/src/app/workflow/services/workflow.worker.spec.ts
+++ b/apps/worker/src/app/workflow/services/workflow.worker.spec.ts
@@ -47,13 +47,11 @@ describe('Workflow Worker', () => {
     const workflowInMemoryProviderService = moduleRef.get<WorkflowInMemoryProviderService>(
       WorkflowInMemoryProviderService
     );
-    const organizationRepository = moduleRef.get<CommunityOrganizationRepository>(CommunityOrganizationRepository);
     const featureFlagsService = moduleRef.get<FeatureFlagsService>(FeatureFlagsService);
 
     workflowWorker = new WorkflowWorker(
       triggerEventUseCase,
       workflowInMemoryProviderService,
-      organizationRepository,
       mockSqsService,
       new PinoLogger({}),
       featureFlagsService
diff --git a/apps/worker/src/app/workflow/services/workflow.worker.ts b/apps/worker/src/app/workflow/services/workflow.worker.ts
index c8098cfe98b..bf2708c3fc4 100644
--- a/apps/worker/src/app/workflow/services/workflow.worker.ts
+++ b/apps/worker/src/app/workflow/services/workflow.worker.ts
@@ -15,7 +15,6 @@ import {
   WorkflowInMemoryProviderService,
   WorkflowWorkerService,
 } from '@novu/application-generic';
-import { CommunityOrganizationRepository } from '@novu/dal';
 import { FeatureFlagsKeysEnum, ObservabilityBackgroundTransactionEnum } from '@novu/shared';
 
 const nr = require('newrelic');
@@ -27,7 +26,6 @@ export class WorkflowWorker extends WorkflowWorkerService {
   constructor(
     private triggerEventUsecase: TriggerEvent,
     public workflowInMemoryProviderService: WorkflowInMemoryProviderService,
-    private organizationRepository: CommunityOrganizationRepository,
     sqsService: SqsService,
     protected logger: PinoLogger,
     private featureFlagsService: FeatureFlagsService
@@ -92,14 +90,6 @@ export class WorkflowWorker extends WorkflowWorkerService {
         return;
       }
 
-      const organizationExists = await this.organizationExist(data);
-
-      if (!organizationExists) {
-        this.logger.warn(`Organization not found for organizationId ${data.organizationId}. Skipping job.`);
-
-        return;
-      }
-
       return await new Promise((resolve, reject) => {
         const _this = this;
 
@@ -128,11 +118,4 @@ export class WorkflowWorker extends WorkflowWorkerService {
       });
     };
   }
-
-  private async organizationExist(data: IWorkflowDataDto): Promise<boolean> {
-    const { organizationId } = data;
-    const organization = await this.organizationRepository.findOne({ _id: organizationId });
-
-    return !!organization;
-  }
 }