Reference

atsas_pipelines.run.run_with_dask(client, inputs, cwd)

Run parallel jobs with Dask.

Parameters

client: dask.distributed.Client

an instance of the Dask client

inputs: list

a list of dictionaries with the input parameters, i.e. the key will be the executable name, and the values will be lists of parameters