我想为不同的文件运行管道，但其中一些不需要所有已定义的节点。我怎样才能通过它们？
【问题讨论】：
要过滤掉管道的几行，您可以简单地从 python 内部过滤管道列表，我最喜欢的方法是使用列表推导。
按名称
nodes_to_run = [node for node in pipeline.nodes if 'dont_run_me' not in node.name]
run(nodes_to_run, io)
按标签
nodes_to_run = [node for node in pipeline.nodes if 'dont_run_tag' not in node.tags]
run(nodes_to_run, io)
可以按与管道节点相关的任何属性（名称、输入、输出、短名称、标签）进行过滤
如果您需要在生产中或从命令行以这种方式运行您的管道，您可以标记您的管道以使用标签运行，或者将自定义 click.option 添加到您的 run 函数中 kedro_cli.py 然后当标志为 True 时运行此过滤器。
注意
这假设您已将管道作为 pipeline 加载到内存中，并将目录作为 io 加载到内存中
【讨论】：
modular pipelines 会在这里帮忙吗？您可以构建两个管道，一个仅包含两个“可选”节点，另一个不包含，然后您可以返回默认管道作为两者的总和。像这样的东西：
def create_pipelines(**kwargs):
two_node_pipeline = Pipeline(node(), node())
rest_of_pipeline = Pipeline(node(), node(), node(), node())
return {
"rest_of_pipeline": rest_of_pipeline,
"__default__": two_node_pipeline + rest_of_pipeline,
}
然后您可以使用kedro run --pipeline rest_of_pipeline 来运行没有这两个节点的管道，或者使用kedro run 来运行具有额外两个节点的管道。
否则，我认为如果您修改kedro_cli 或ProjectContext 或run.py，无论是什么，都应该很容易自己添加--except 功能。我可能会考虑这样做...
Kedro 会自动对节点进行排序，根据 toposort，看这个之前的回答：How to run the nodes in sequence as declared in kedro pipeline?
【讨论】：
您也可以使用--to-nodes CLI 选项：kedro run --to-nodes node1,node2。在内部这将调用pipeline.to_nodes("node1", "node2") - method docs。请注意，您仍然需要确定必须运行的“最终”节点列表。
【讨论】：