Unanswered
Thread Re: Pipelines And How They'Re Meant To Be Used / How Long They Take To Orchestrate.
# imports
...
if __name__ == "__main__:
pipe = PipelineController(...)
# after instantiation, before "the code" that creates the pipeline.
# normal tasks can handle task.execute_remotely() at this stage...
pipe = add_steps_to_pipe(pipe)
...
# after the pipeline is defined. best I can tell, *has* to be last thing in code.
pipe.start_locally() # or just .start()
39 Views
0
Answers
3 months ago
3 months ago