From 1cd76e465ab387691837141b5df578125a103c75 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E7=8E=8B=E8=89=AF?= <841369634@qq.com> Date: Tue, 17 Mar 2026 12:52:41 +0800 Subject: [PATCH] =?UTF-8?q?bugfix:=20`=E5=8F=98=E9=87=8F=E6=8B=86=E5=88=86?= =?UTF-8?q?`=EF=BC=8C=E8=87=AA=E5=8A=A8=E8=BD=AC=E6=8D=A2=20`str`=20?= =?UTF-8?q?=E5=8F=82=E6=95=B0=EF=BC=8C=E9=81=BF=E5=85=8D=E5=8F=98=E9=87=8F?= =?UTF-8?q?=E6=8B=86=E5=88=86=E5=A4=B1=E8=B4=A5=E3=80=82?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../impl/base_variable_splitting_node.py | 7 +++++++ 1 file changed, 7 insertions(+) diff --git a/apps/application/flow/step_node/variable_splitting_node/impl/base_variable_splitting_node.py b/apps/application/flow/step_node/variable_splitting_node/impl/base_variable_splitting_node.py index 447609747e5..c11b79a7b30 100644 --- a/apps/application/flow/step_node/variable_splitting_node/impl/base_variable_splitting_node.py +++ b/apps/application/flow/step_node/variable_splitting_node/impl/base_variable_splitting_node.py @@ -6,6 +6,7 @@ @dateļ¼š2025/10/13 15:02 @desc: """ +import json from jsonpath_ng import parse from application.flow.i_step_node import NodeResult @@ -40,6 +41,12 @@ def save_context(self, details, workflow_manage): self.context['exception_message'] = details.get('err_message') def execute(self, input_variable, variable_list, **kwargs) -> NodeResult: + if type(input_variable).__name__ == "str": + try: + input_variable = json.loads(input_variable) + except Exception: + pass + self.context['request'] = input_variable response = {v['field']: smart_jsonpath_search(input_variable, v['expression']) for v in variable_list} return NodeResult({'result': response, **response}, {})