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', }); }