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)