kedro.runner.SequentialRunner

class kedro.runner.SequentialRunner[source]

SequentialRunner is an AbstractRunner implementation. It can be used to run the Pipeline in a sequential manner using a topological sort of provided nodes.

__init__()

Initialize self. See help(type(self)) for accurate signature.

Methods

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.