Sorry I think I probably need more details about what you are asking here.
So, does the module represent a workflow step here? For example,
We’ll have a pipeline
M1 -> M3 -> M4.
M2 - /
For this, we can distinguish them from the inputs:
where M3 might be:
def m3(m1_input, m2_input): ...
Or do you mean module3 will be a workflow job and module1, module2 are the place where trigger module3 to update it’s internal state?
First of all, nothing is shared across runs. And you can get the step output with the named step which has been added recently.
def f(): ...
We don’t support stateful steps directly right now.