Pipeline Runners

Given some pipeline arguments method, pass to one of the pipeline execution methods below.

This method will delegate to the appropriate pipeline, and is in charge of sending the completion email.

pipeline(args: RuntimeArguments)

Pipeline that creates its own client from the provided runtime arguments

pipeline_with_client(args: RuntimeArguments, client: Client)

Pipeline that is run using an existing client.

This can be useful in tests, or when a dask client requires some more complex configuration.