kedro.runner.ParallelRunner

class kedro.runner.ParallelRunner[source]

ParallelRunner is an AbstractRunner implementation. It can be used to run the Pipeline in parallel groups formed by toposort.

__init__()[source]

Instantiates the runner by creating a Manager.

Methods

__init__() Instantiates the runner by creating a Manager.
create_default_data_set(ds_name, max_loads) Factory method for creating the default data set for the runner.
run(pipeline, catalog) Run the Pipeline using the DataSet``s provided by ``catalog and save results back to the same objects.
run_only_missing(pipeline, catalog) Run only the missing outputs from the Pipeline using the DataSet``s provided by ``catalog and save results back to the same objects.