From 3d95a946a899443a82a7263687abf3d2a0c7b3cc Mon Sep 17 00:00:00 2001 From: kami Date: Tue, 26 May 2026 14:51:09 +0400 Subject: [PATCH] fix(server): run orchestrator in module scope to survive WS disconnect --- .../kotlin/com/correx/apps/server/ws/GlobalStreamHandler.kt | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/apps/server/src/main/kotlin/com/correx/apps/server/ws/GlobalStreamHandler.kt b/apps/server/src/main/kotlin/com/correx/apps/server/ws/GlobalStreamHandler.kt index 23dd1b39..fc7d2c50 100644 --- a/apps/server/src/main/kotlin/com/correx/apps/server/ws/GlobalStreamHandler.kt +++ b/apps/server/src/main/kotlin/com/correx/apps/server/ws/GlobalStreamHandler.kt @@ -193,7 +193,7 @@ class GlobalStreamHandler(private val module: ServerModule) { } val sessionId: SessionId = TypeId(UUID.randomUUID().toString()) log.info("starting session={} workflow={}", sessionId.value, msg.workflowId) - session.launch { + module.moduleScope.launch { runCatching { module.orchestrator.run(sessionId, graph, module.defaultOrchestrationConfig) } .onFailure { ex -> log.error("run failed for session={}: {}", sessionId.value, ex.message, ex)