From aeaeb28a0bd61b3c832df6966f23adae69729ff5 Mon Sep 17 00:00:00 2001 From: -LAN- Date: Mon, 8 Sep 2025 16:17:43 +0800 Subject: [PATCH 1/2] fix: add variable_pool to pipeline WorkflowEntry Signed-off-by: -LAN- --- api/core/app/apps/pipeline/pipeline_runner.py | 1 + 1 file changed, 1 insertion(+) diff --git a/api/core/app/apps/pipeline/pipeline_runner.py b/api/core/app/apps/pipeline/pipeline_runner.py index 57cc1c316c..12506049aa 100644 --- a/api/core/app/apps/pipeline/pipeline_runner.py +++ b/api/core/app/apps/pipeline/pipeline_runner.py @@ -176,6 +176,7 @@ class PipelineRunner(WorkflowBasedAppRunner): invoke_from=self.application_generate_entity.invoke_from, call_depth=self.application_generate_entity.call_depth, graph_runtime_state=graph_runtime_state, + variable_pool=variable_pool, ) generator = workflow_entry.run() From ef974e484b9f29f59d9c35c5d97d04a60d7447f6 Mon Sep 17 00:00:00 2001 From: -LAN- Date: Mon, 8 Sep 2025 16:43:47 +0800 Subject: [PATCH 2/2] fix: handle None env vars Signed-off-by: -LAN- --- api/models/workflow.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/api/models/workflow.py b/api/models/workflow.py index 37ce74c665..f4044a8a2a 100644 --- a/api/models/workflow.py +++ b/api/models/workflow.py @@ -354,7 +354,7 @@ class Workflow(Base): if not tenant_id: return [] - environment_variables_dict: dict[str, Any] = json.loads(self._environment_variables) + environment_variables_dict: dict[str, Any] = json.loads(self._environment_variables or "{}") results = [ variable_factory.build_environment_variable_from_mapping(v) for v in environment_variables_dict.values() ]