Hey there!I’m trying to build a pipeline with the help of decorators. I have a one-step pipeline, and the step is imported from a different pipeline, marked up with the component decorator.
from X import my_function
@PipelineDecorator.pipeline(…)
def execute_pipeline(param1, param2):
result = my_function(param1, param2)
if __name__ == "__main__":
execute_pipeline(«value_1», «value_2»)
When I start the pipeline from my IDE, it works fine. But the whole idea is to run it with different params from the UI, and here comes the problem. When I try to do so, changing the values of param1
and param2
, I see the new values in the run info window of the whole pipeline , but in the run info of its step the values are old, e.g. the ones that I used when I ran the pipeline from my IDE («value_1», «value_2»).
Am I missing something obvious? I see that there’s function_kwargs
for the pipeline controller, and that actually works with my pipeline, (I rewrote it using the pipeline controller and when I run it from the UI everything’s ok) but I would rather figure out how to make it right with the decorators and use them. Thanks in advance!