kedro.runner

描述

kedro.runner 提供了能够执行 Pipeline 实例的运行器。

函数

kedro.runner.run_node(node, catalog, ...[, ...])

使用来自catalog的输入和输出运行单个Node。

类

kedro.runner.AbstractRunner([is_async, ...])	AbstractRunner 是所有 Pipeline 运行器实现的基类。
kedro.runner.ParallelRunner([max_workers, ...])	ParallelRunner 是 AbstractRunner 的一个实现。
kedro.runner.SequentialRunner([is_async, ...])	SequentialRunner 是 AbstractRunner 的一个实现。
kedro.runner.ThreadRunner([max_workers, ...])	ThreadRunner 是 AbstractRunner 的一个实现。