fix: use existing workflow

This commit is contained in:
Nevo David 2026-01-06 16:35:42 +07:00
parent 7ac99e8259
commit 5f1a77a3b0
3 changed files with 3 additions and 0 deletions

View File

@ -47,6 +47,7 @@ export class PostActivity {
workflowId: `post_${post.id}`,
taskQueue: 'main',
signal: 'poke',
workflowIdConflictPolicy: 'USE_EXISTING',
signalArgs: [],
args: [
{

View File

@ -61,6 +61,7 @@ export class NotificationService {
],
],
taskQueue: 'main',
workflowIdConflictPolicy: 'USE_EXISTING',
args: [{ organizationId: orgId }],
typedSearchAttributes: new TypedSearchAttributes([
{

View File

@ -42,6 +42,7 @@ export class EmailService {
signal: 'sendEmail',
args: [{ queue: [] }],
signalArgs: [{ to, subject, html, replyTo }],
workflowIdConflictPolicy: 'USE_EXISTING',
});
}