diff --git a/src/services/platform.service.ts b/src/services/platform.service.ts index b8a4ddd..beba37a 100644 --- a/src/services/platform.service.ts +++ b/src/services/platform.service.ts @@ -347,6 +347,7 @@ const handlePlatformCleanup = async (platform: HydratedDocument): Pro case PlatformNames.Website: { if (platform.metadata?.scheduleId) { await websiteService.coreService.deleteWebsiteSchedule(platform.metadata.scheduleId); + await websiteService.coreService.terminateWebsiteWorkflow(platform.community.toString()); } break; } @@ -373,7 +374,7 @@ const handleWebsiteResourceChanges = async ( if (oldResources === newResources) return; if (platform.metadata.scheduleId) { - await websiteService.coreService.deleteWebsiteSchedule(platform.metadata.scheduleId); + // await websiteService.coreService.deleteWebsiteSchedule(platform.metadata.scheduleId); await websiteService.coreService.terminateWebsiteWorkflow(platform.community.toString()); updateBody.metadata.scheduleId = null; } diff --git a/src/services/temporal/website.service.ts b/src/services/temporal/website.service.ts index c39a1e7..24f2185 100644 --- a/src/services/temporal/website.service.ts +++ b/src/services/temporal/website.service.ts @@ -27,7 +27,6 @@ class TemporalWebsiteService extends TemporalCoreService { try { const client: Client = await this.getClient(); - console.log('type', typeof platformId.toString()); return client.schedule.create({ scheduleId: `website/${uuidv4()}`, spec: { @@ -62,8 +61,10 @@ class TemporalWebsiteService extends TemporalCoreService { } public async terminateWorkflow(workflowId: string): Promise { + console.log(workflowId); const client: Client = await this.getClient(); const handle = client.workflow.getHandle(workflowId); + console.log(handle); await handle.terminate(); } }