@@ -366,10 +366,12 @@ def _validate_step_command(
366
366
inputs = step .get ("inputs" , [])
367
367
outputs = step .get ("outputs" , [])
368
368
previous_step_outputs = previous_step .get ("outputs" , [])
369
+
369
370
step_vars = self ._set_step_variables (
370
371
inputs = inputs ,
371
372
outputs = outputs ,
372
373
previous_step_outputs = previous_step_outputs ,
374
+ workflow_variables = all_variables ,
373
375
)
374
376
375
377
all_variables |= step_vars
@@ -483,6 +485,7 @@ def _set_step_variables(
483
485
inputs : list [dict [str , Any ]],
484
486
outputs : list [dict [str , Any ]],
485
487
previous_step_outputs : list [dict [str , Any ]],
488
+ workflow_variables : dict [str , Any ],
486
489
) -> dict [str , Any ]:
487
490
"""Prepare input- and output variables for the following step.
488
491
@@ -496,7 +499,7 @@ def _set_step_variables(
496
499
p_val = ""
497
500
val = item ["from" ]
498
501
if "workflow-input" in val .keys ():
499
- p_val = val ["workflow-input" ]
502
+ p_val = workflow_variables [ val ["workflow-input" ] ]
500
503
elif "step" in val .keys ():
501
504
for out in previous_step_outputs :
502
505
if out ["output" ] == val ["output" ]:
0 commit comments