fix: correct redis set when update node execution && fix openAPI run … (#639)

2025-08-08 10:44:08 +08:00
parent a3f68cfa01
commit 7697b6fb47
2 changed files with 7 additions and 3 deletions
--- a/backend/domain/workflow/internal/repo/execute_history_store.go
+++ b/backend/domain/workflow/internal/repo/execute_history_store.go
@@ -303,7 +303,7 @@ func (e *executeHistoryStoreImpl) UpdateNodeExecutionStreaming(ctx context.Conte

 	key := fmt.Sprintf(nodeExecOutputKey, execution.ID)

-	if err := e.redis.Set(ctx, key, execution.Output, nodeExecDataExpiry).Err(); err != nil {
+	if err := e.redis.Set(ctx, key, *execution.Output, nodeExecDataExpiry).Err(); err != nil {
 		return vo.WrapError(errno.ErrRedisError, err)
 	}