From 5f1a77a3b0b1ef9f279c2eae15ba1a0b343b6f9f Mon Sep 17 00:00:00 2001
From: Nevo David <me@nevos.io>
Date: Tue, 6 Jan 2026 16:35:42 +0700
Subject: [PATCH] fix: use existing workflow

---
 apps/orchestrator/src/activities/post.activity.ts                | 1 +
 .../src/database/prisma/notifications/notification.service.ts    | 1 +
 libraries/nestjs-libraries/src/services/email.service.ts         | 1 +
 3 files changed, 3 insertions(+)

diff --git a/apps/orchestrator/src/activities/post.activity.ts b/apps/orchestrator/src/activities/post.activity.ts
index 1db29ca7..e6dc8fd7 100644
--- a/apps/orchestrator/src/activities/post.activity.ts
+++ b/apps/orchestrator/src/activities/post.activity.ts
@@ -47,6 +47,7 @@ export class PostActivity {
           workflowId: `post_${post.id}`,
           taskQueue: 'main',
           signal: 'poke',
+          workflowIdConflictPolicy: 'USE_EXISTING',
           signalArgs: [],
           args: [
             {
diff --git a/libraries/nestjs-libraries/src/database/prisma/notifications/notification.service.ts b/libraries/nestjs-libraries/src/database/prisma/notifications/notification.service.ts
index a8ba9e12..1deb7dae 100644
--- a/libraries/nestjs-libraries/src/database/prisma/notifications/notification.service.ts
+++ b/libraries/nestjs-libraries/src/database/prisma/notifications/notification.service.ts
@@ -61,6 +61,7 @@ export class NotificationService {
               ],
             ],
             taskQueue: 'main',
+            workflowIdConflictPolicy: 'USE_EXISTING',
             args: [{ organizationId: orgId }],
             typedSearchAttributes: new TypedSearchAttributes([
               {
diff --git a/libraries/nestjs-libraries/src/services/email.service.ts b/libraries/nestjs-libraries/src/services/email.service.ts
index 529228e1..474520b2 100644
--- a/libraries/nestjs-libraries/src/services/email.service.ts
+++ b/libraries/nestjs-libraries/src/services/email.service.ts
@@ -42,6 +42,7 @@ export class EmailService {
         signal: 'sendEmail',
         args: [{ queue: [] }],
         signalArgs: [{ to, subject, html, replyTo }],
+        workflowIdConflictPolicy: 'USE_EXISTING',
       });
   }