Use API
Create a pipeline
Set inputs of the pipeline
Set outputs of the pipeline
Start the pipeline
The Start()
function in the code snippet above initiates the pipeline execution but does not wait for it to complete. Instead, it spawns a goroutine by calling go pipeline.Run()
and returns immediately. On the other hand, pipeline.Run()
is a blocking function that waits until the pipeline finishes its execution before returning control.
Last updated