diff --git a/api/core/workflow/workflow_entry.py b/api/core/workflow/workflow_entry.py index b14c6fafbd9fdc..f622d0b2d01f28 100644 --- a/api/core/workflow/workflow_entry.py +++ b/api/core/workflow/workflow_entry.py @@ -239,6 +239,10 @@ def mapping_user_inputs_to_variable_pool( ): raise ValueError(f"Variable key {node_variable} not found in user inputs.") + # environment variable already exist in variable pool, not from user inputs + if variable_pool.get(variable_selector): + continue + # fetch variable node id from variable selector variable_node_id = variable_selector[0] variable_key_list = variable_selector[1:]