diff --git a/src/services/website/core.service.ts b/src/services/website/core.service.ts index 9070926..15a6f81 100644 --- a/src/services/website/core.service.ts +++ b/src/services/website/core.service.ts @@ -27,9 +27,9 @@ async function deleteWebsiteSchedule(scheduleId: string): Promise { } } -async function terminateWebsiteWorkflow(workflowId: string): Promise { +async function terminateWebsiteWorkflow(communityId: string): Promise { try { - await temporalWebsite.terminateWorkflow(workflowId); + await temporalWebsite.terminateWorkflow(`website:ingestor:${communityId}`); } catch (error) { logger.error(error, 'Failed to terminate website workflow.'); throw new ApiError(590, 'Failed to terminate website workflow.');