@@ -431,6 +431,16 @@ search_inputs_in_output(:process3, in_, out_)
431431(process4 = (:var1, :var2),)
432432```
433433"""
434+
435+
436+ function extract_mapped_outputs (timestep_mapped_outputs)
437+ extracted = Pair[]
438+ for pair in timestep_mapped_outputs
439+ push! (extracted, Pair (first (last (pair)). name_to, last (last (pair))))
440+ end
441+ return extracted
442+ end
443+
434444function search_inputs_in_output (process, inputs, outputs, timestep_mapped_outputs= Dict {Symbol,NamedTuple} ())
435445 # proc, ins, outs
436446 # get the inputs of the node:
@@ -442,7 +452,7 @@ function search_inputs_in_output(process, inputs, outputs, timestep_mapped_outpu
442452 vars_output = flatten_vars (pairs_vars_output)
443453 vars_all_outputs = vars_output
444454 if haskey (timestep_mapped_outputs, proc_output)
445- vars_all_outputs = (; vars_output... , flatten_vars (timestep_mapped_outputs[proc_output])... )
455+ vars_all_outputs = (; vars_output... , extract_mapped_outputs (timestep_mapped_outputs[proc_output])... )
446456 end
447457
448458 inputs_in_outputs = vars_in_variables (vars_input, vars_all_outputs)
@@ -549,14 +559,6 @@ function search_inputs_in_multiscale_output(process, organ, inputs, soft_dep_gra
549559 return inputs_as_output_of_other_scale
550560end
551561
552- function extract_mapped_outputs (timestep_mapped_outputs)
553- extracted = Pair[]
554- for pair in timestep_mapped_outputs
555- push! (extracted, Pair (first (last (pair)). name_to, last (last (pair))))
556- end
557- return extracted
558- end
559-
560562function add_input_as_output! (inputs_as_output_of_other_scale, soft_dep_graphs, organ_source, variable, value)
561563
562564 timestep_mapped_outputs = soft_dep_graphs[organ_source][:timestep_mapped_outputs ]
0 commit comments