Seth Stokes
02/18/2025, 10:33 PMfinal_result will all the step functions be applied to upstream_int when I get it in the function body? What if it were pipe_output?
@pipe_input(
step(_add_one),
step(_multiply, y=2),
step(_sum, y=value(3)),
step(_multiply, y=source("upstream_node_to_multiply")),
)
def final_result(upstream_int: int) -> int:
pdb.set_trace()
return upstream_int
Slack ConversationStefan Krawczyk
02/18/2025, 10:39 PMStefan Krawczyk
02/18/2025, 10:40 PMupstream_int and in the function body that’s what you’ll get.
If it was pipe_output those steps would be applied to the value returned by final_result.Seth Stokes
02/18/2025, 10:57 PMpipe_output then the `pipe`'d`step` s would not have yet been applied?Stefan Krawczyk
02/18/2025, 10:59 PM