From 6942e05f1a2c7bd1571c5b3b7a73f8ce62d64981 Mon Sep 17 00:00:00 2001
From: qhd <1766646056@qq.com>
Date: Tue, 23 Jun 2026 16:40:42 +0800
Subject: [PATCH] =?UTF-8?q?fix:=20=E8=A1=A5=E5=85=85Lambda=E8=8A=82?=
 =?UTF-8?q?=E7=82=B9HTTP=E8=AF=B7=E6=B1=82=E7=A9=BA=E7=BB=93=E6=9E=9C?=
 =?UTF-8?q?=E9=94=99=E8=AF=AF=E6=8F=90=E7=A4=BA?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 workflow/service/flow/lambda_node_imp.go | 8 ++++++++
 1 file changed, 8 insertions(+)

diff --git a/workflow/service/flow/lambda_node_imp.go b/workflow/service/flow/lambda_node_imp.go
index 7fa3379..0387182 100644
--- a/workflow/service/flow/lambda_node_imp.go
+++ b/workflow/service/flow/lambda_node_imp.go
@@ -875,6 +875,8 @@ func HttpNode(ctx context.Context, nodeInput *flowDto.NodeExecutionInput) ([]nod
 		return nil, err
 	}
 
+	var e = ""
+
 	finalResult := make(map[string]any)
 	if responseType == "sync" {
 		httpResultJson := gconv.String(rawHttpResult)
@@ -884,6 +886,7 @@ func HttpNode(ctx context.Context, nodeInput *flowDto.NodeExecutionInput) ([]nod
 				finalResult[key] = gjson.Get(httpResultJson, path).Value()
 			}
 		}
+		e = fmt.Sprintf("%v", httpResultJson)
 	}
 	if responseType == "callback" {
 		var waitResult any
@@ -910,11 +913,16 @@ func HttpNode(ctx context.Context, nodeInput *flowDto.NodeExecutionInput) ([]nod
 				}
 			}
 		}
+		e = fmt.Sprintf("%v", bodyStr)
 	}
 	if responseType == "pull" {
 
 	}
 
+	if g.IsEmpty(finalResult) {
+		return nil, fmt.Errorf("http请求异常，返回结果为空：%v", e)
+	}
+
 	outputRes := make([]node.NodeFormField, 0)
 	for i, item := range finalResult {
 		if nodeInput.Config.IsSaveFile {