diff --git a/services/apps/entity_merging_worker/src/activities/organizations.ts b/services/apps/entity_merging_worker/src/activities/organizations.ts index 9f75457014..33dff20a68 100644 --- a/services/apps/entity_merging_worker/src/activities/organizations.ts +++ b/services/apps/entity_merging_worker/src/activities/organizations.ts @@ -38,11 +38,10 @@ export async function recalculateActivityAffiliationsOfOrganizationSynchronous( organizationId: string, tenantId: string, ): Promise { - await startChild('organizationUpdate', { + await svc.temporal.workflow.start('organizationUpdate', { taskQueue: 'profiles', workflowId: `${TemporalWorkflowId.ORGANIZATION_UPDATE}/${tenantId}/${organizationId}`, - cancellationType: ChildWorkflowCancellationType.ABANDON, - parentClosePolicy: ParentClosePolicy.PARENT_CLOSE_POLICY_ABANDON, + followRuns: true, retry: { maximumAttempts: 10, },