File tree Expand file tree Collapse file tree 1 file changed +10
-1
lines changed Expand file tree Collapse file tree 1 file changed +10
-1
lines changed Original file line number Diff line number Diff line change @@ -510,15 +510,24 @@ def _prepare_step(
510
510
for connector in connections :
511
511
assert connector .in_ in prior_step ["variables" ]
512
512
if connector .out == combiner_input_variable :
513
+ # Each instance may have a different value
513
514
input_source_list .append (
514
515
prior_step ["variables" ][connector .in_ ]
515
516
)
516
- else :
517
+ elif replica == 0 :
518
+ # Only the first instance value are of interest,
519
+ # the rest wil be the same - only one variable
520
+ # is a list of different values.
517
521
variables [connector .out ] = prior_step ["variables" ][
518
522
connector .in_
519
523
]
524
+ # Now we have accumulated the prior steps values (files)
525
+ # set the combiner's corresponding input variable...
520
526
variables [combiner_input_variable ] = input_source_list
521
527
else :
528
+ # Not a preior step for a combiner,
529
+ # or not a step being combined in a combiner.
530
+ #
522
531
# Retrieve the prior "running" step
523
532
# in order to get the variables that were set there...
524
533
prior_step , _ = self ._wapi_adapter .get_running_workflow_step_by_name (
You can’t perform that action at this time.
0 commit comments