fix: 修复网关任务并发等待竞态导致永久阻塞

workflow/service/flow/lambda_node_util.go

@@ -455,27 +455,25 @@ func GetModelResult(ctx context.Context, sessionId string, nodeInput *flowDto.No
 				//updateTokenCount(ctx, nodeInput.NodeExecutionId, modelInfo.Model.ResponseTokenField, taskResult)
 			}
 		} else {
-			taskIdList := make([]string, len(composeResult.Messages.Rounds))
-
-			for idx, item := range composeResult.Messages.Rounds {
-				taskId, err := createGatewayTaskOnly(ctx, composeResult.EpicycleId, nodeInput.Config.ModelConfig.ModelName, item)
-				if err != nil {
-					return nil, err
-				}
-				taskIdList[idx] = taskId
-			}
-
 			// 全局共享子上下文，实现一处报错全部终止
 			subCtx, globalCancel := context.WithCancel(ctx)
 			defer globalCancel() // 函数退出兜底释放
 
 			var wg sync.WaitGroup
-			errChan := make(chan error, len(taskIdList))
+			errChan := make(chan error, len(composeResult.Messages.Rounds))
 
 			// 加互斥锁保护结果map
 			var mu sync.Mutex
 
-			for idx, taskId := range taskIdList {
+			// 每个任务创建后立即启动等待协程：把「回调 vs Wait 注册」的竞争窗口从整个创建循环
+			// 压缩到微秒级，避免创建期间完成的回调被 Notify 静默丢弃导致 Wait 永久阻塞
+			for idx, item := range composeResult.Messages.Rounds {
+				taskId, err := createGatewayTaskOnly(ctx, composeResult.EpicycleId, nodeInput.Config.ModelConfig.ModelName, item)
+				if err != nil {
+					globalCancel() // 取消已启动的等待协程，避免泄漏
+					return nil, err
+				}
+
 				wg.Add(1)
 
 				go func(idx int, taskId string) {