@@ -627,9 +627,9 @@ def _prepare_step(
627
627
assert "instance_id" in prior_step
628
628
p_i_id : str = prior_step ["instance_id" ]
629
629
p_i_dir : str = f"{ self ._instance_id_dir_prefix } { p_i_id } "
630
- # Get prior step Job (tro look for inputs)
630
+ # Get prior step Job (to look for its outputs that are our inputs)
631
631
# (if we're not a combiner)
632
- p_job_inputs : dict [str , Any ] = {}
632
+ p_job_outputs : dict [str , Any ] = {}
633
633
if not we_are_a_combiner :
634
634
p_step_spec : dict [str , Any ] = get_step_specification (
635
635
wf , prior_step_name
@@ -642,14 +642,14 @@ def _prepare_step(
642
642
)
643
643
_LOGGER .info ("API.get_job() got %s\n " , str (p_job ))
644
644
assert p_job
645
- p_job_inputs = job_definition_decoder .get_inputs (p_job )
645
+ p_job_outputs = job_definition_decoder .get_outputs (p_job )
646
646
# Copy "in" value to "out"...
647
647
# (prefixing inputs with instance directory if required)
648
648
assert "variables" in prior_step
649
649
for connector in connections :
650
650
assert connector .in_ in prior_step ["variables" ]
651
651
value : str = prior_step ["variables" ][connector .in_ ]
652
- if not we_are_a_combiner and connector .in_ in p_job_inputs :
652
+ if not we_are_a_combiner and connector .in_ in p_job_outputs :
653
653
# Prefix with prior-step's instance directory
654
654
value = f"{ p_i_dir } /{ value } "
655
655
prime_variables [connector .out ] = value
@@ -769,7 +769,7 @@ def _launch(
769
769
rwf_id : str = rwf ["id" ]
770
770
project_id = rwf ["project" ]["id" ]
771
771
772
- _LOGGER .info ("SPR.variable =%s" , step_preparation_response .variables )
772
+ _LOGGER .info ("SPR.variables =%s" , step_preparation_response .variables )
773
773
_LOGGER .info (
774
774
"SPR.replica_variable=%s" , step_preparation_response .replica_variable
775
775
)
0 commit comments