kedro.runner.SequentialRunner¶

class kedro.runner.SequentialRunner(is_async=False)[source]¶

Bases: kedro.runner.runner.AbstractRunner

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

Attributes

Methods

`SequentialRunner.create_default_data_set`(ds_name)	Factory method for creating the default data set for the runner.
`SequentialRunner.run`(pipeline, catalog[, run_id])	Run the `Pipeline` using the DataSet``s provided by ``catalog and save results back to the same objects.
`SequentialRunner.run_only_missing`(pipeline, …)	Run only the missing outputs from the `Pipeline` using the DataSet``s provided by ``catalog and save results back to the same objects.

__init__(is_async=False)[source]¶

Instantiates the runner classs.

Parameters: is_async (bool) – If True, the node inputs and outputs are loaded and saved asynchronously with threads. Defaults to False.

create_default_data_set(ds_name)[source]¶

Factory method for creating the default data set for the runner.

Parameters: ds_name (str) – Name of the missing data set
Return type: AbstractDataSet
Returns: An instance of an implementation of AbstractDataSet to be used for all unregistered data sets.

run(pipeline, catalog, run_id=None)¶

Run the Pipeline using the DataSet``s provided by ``catalog and save results back to the same objects.

Parameters

Raises

ValueError – Raised when Pipeline inputs cannot be satisfied.

Return type

Dict[str, Any]

Returns

Any node outputs that cannot be processed by the DataCatalog. These are returned in a dictionary, where the keys are defined by the node outputs.

run_only_missing(pipeline, catalog)¶