管道在kedro中找不到节点
在kedro中，管道是指数据处理的流程，它由一系列节点组成。每个节点代表一个数据处理的步骤，可以是数据的读取、转换、清洗、分析等操作。管道的目的是将数据从一个节点传递到另一个节点，形成数据处理的流程。
当在kedro中找不到节点时，可能有以下几个原因：
- 节点未定义：首先需要确认在kedro项目中是否正确定义了节点。节点通常在
pipeline.py文件中定义，可以使用@node装饰器来标记一个函数作为节点。确保节点的定义正确，并且在使用时能够被正确引用。 - 节点名称拼写错误：检查节点的名称是否拼写正确，包括大小写。在kedro中，节点的名称是唯一的，如果名称拼写错误，将无法找到对应的节点。
- 节点未在管道中注册：在kedro中，需要将节点注册到管道中才能被执行。在
pipeline.py文件中，使用create_pipeline函数创建管道时，确保已经将节点添加到了管道中。 - 依赖关系错误：如果节点之间存在依赖关系，即某个节点的输出作为另一个节点的输入，需要确保依赖关系正确。在kedro中，可以使用
@inputs和@outputs装饰器来定义节点的输入和输出。
如果以上步骤都正确无误，但仍然找不到节点，可以考虑以下解决方法：
- 检查kedro版本：确保使用的是最新版本的kedro，并查看官方文档或社区论坛是否存在相关问题或解决方案。
- 查看日志信息：在kedro运行时，可以查看日志信息以获取更多的调试信息。日志信息可能包含有关节点查找失败的详细错误消息，从而帮助定位问题。
- 寻求帮助：如果以上方法仍然无法解决问题，可以向kedro的官方支持渠道或社区论坛寻求帮助。提供详细的错误描述、代码示例和相关环境信息，有助于其他开发者更好地理解和解决问题。
腾讯云相关产品和产品介绍链接地址：
相关·内容
在Kedro管道中，节点(类似python函数)是按顺序声明的。在某些情况下，一个节点的输入是前一个节点的输出。但是，有时在命令行中调用kedro时，节点不会按顺序运行。
在kedro文档中，它说默认情况下节点是按顺序运行的。
我的run.py代码：
def main(
tags: Iterable[str] = None,
env: str = None,
runner: Type[AbstractRunner] = None,
node_names: Iterable[str] = None,
from_nodes: Iterable[str] = None,
to_nodes: Iter
浏览 0提问于2019-11-04得票数 5
回答已采纳
我正在尝试使用kedro来运行工作流。下图是我的工作流程(节点1-3是顺序的，节点31、32和33是节点3的三个分支)。您可以看到kedro是按从1到3的顺序运行的，这是由于节点之间明显的依赖关系。然而，当涉及到31，32和33个节点时，kedro实际上是随机运行的。它可以从31、32或33开始。谁知道我可以让kedro先跑31，然后跑32，再跑33？谢谢! ? 我已经尝试标记所有节点，但是当kedro进入节点31到33时，运行顺序是随机保持的
浏览 13提问于2021-09-10得票数 0
如何使用Jupyter Notebook作为Kedro管道中的节点？这不同于。我想要做的是使用完整的notebook作为节点。
浏览 6提问于2020-09-15得票数 0
由于kedro根据节点输入/输出确定执行图，因此执行的顺序是不确定的。它可以在不同的运行中变化。
即使我设置了一个种子，我也可能在不同的运行中采样不同的数据。
假设我有3个节点，它们彼此不依赖。第一次运行: A->B->C 2st运行: B->A->C
我会得到不同的结果，因为随机生成器序列不同。
浏览 1提问于2020-11-06得票数 0
2回答
Kedro -内存管理
、、、
我正在处理一个Kedro 0.17.2项目，该项目正在处理内存不足的问题，我正在努力减少内存占用。
我正在使用来自mprof库的memory-profiler进行分析，我注意到总是有一个子进程，并且在正在运行的节点中的第一次计算之后，主进程中的内存似乎重复。Kedro有可能复制内存中的数据吗？如果是的话，是否有办法避免这种情况？
备注：
我在用SequentialRunner
我不使用is_async cli选项
在节点执行中，我既不使用多线程也不使用多处理
浏览 1提问于2021-10-16得票数 3
回答已采纳
在IPython中，我可以运行data = catalog.load('my_dataset')，以便在catalog.yml文件中加载指定为“my_dataset”的数据集。pthon脚本中的等效命令是什么？我需要进口什么？
浏览 31提问于2022-10-19得票数 0
回答已采纳
3回答
我想用不同的输入在jupyter笔记本上运行kedro管道，如下所示：
data = catalog.load('my_dataset')
params = catalog.load('params:my_params')
pipelines['my_pipeline'](data=my_dataset, params=my_params)
有办法这样做吗？另外，如果我必须向其他节点(例如第二个节点)提供一些输入，那么如何实现呢？
浏览 22提问于2022-10-03得票数 0
回答已采纳
不久前，我开始了一个Kedro项目，并开始构建管道中的不同部分，它们之间只进行细微的交互。在某些情况下一点也不多。
因此，随着项目的发展，由于安装过程使用requirement.txt，我开始遇到依赖关系的问题。
因此，我想问的是，Kedro是否意味着被设计为单回购。如果是，请举例说明如何做到这一点？提前谢谢。
浏览 6提问于2022-04-25得票数 0
2回答
Kedro条件管道(或备选方案)
、、、、
我目前正在研究我们管道的不同设计模式选项。Kedro框架似乎是一个很好的选择(允许模块化设计模式、可视化方法等)。
管道应该在许多模块中创建，这些模块要么将输出写入文件，要么将其通过管道传输到下一个模块(取决于条件)。在第二种情况下(管道到下一个模块)，kedro失败，因为它将整个输出读取到内存中，然后前进到下一步(或者是否存在unix类型管道的可能性)？我正在使用大数据，所以这对我来说是合适的。为什么这个工作流不同于通常的unix管道？- unix管道正在读取特定的缓冲区大小并立即转发(我猜这会交换到磁盘，而不是保存在内存中？)如果你能给我指出另一个允许这种功能的框架，我将不胜感激(我也不介
浏览 5提问于2021-02-22得票数 0
与前面描述的类似，我遵循了，在创建管道的步骤中，运行kedro run --node=preproces_companies_node时得到了以下错误
ValueError: Pipeline does not contain nodes named ['preprocess_companies_node'].
相关文件将按照本教程中的指示指定。
src/kedro_tutorial/pipelines/data_processing/pipeline.py
from kedro.pipeline import Pipeline, node
from .nodes
浏览 3提问于2021-07-19得票数 1
如何使用管道从内存/文件中运行？我认为功能在那里，但我不知道我怎么能写成这样的管道。
我的用例是：
普通管道，从步骤1到步骤10从步骤2运行到步骤10。
想象一下，在步骤1，我将写一个数据文件到一个csv，第2步将需要从中读取。如果从步骤1运行，我希望在内存中传递该数据(以节省读取时间)。但是，如果我从第二步开始运行，我将需要阅读csv。
用Kedro这样做的最佳实践是什么？
浏览 6提问于2020-08-18得票数 1
1回答
我在凯德罗有一条管道看起来是这样的：
from kedro.pipeline import Pipeline, node
from .nodes import *
def foo():
return Pipeline([
node(a, inputs=["train_x", "test_x"], outputs=dict(bar_a="bar_a"), name="A"),
node(b, inputs=["train_x", "test_x"], outp
浏览 4提问于2021-07-19得票数 2
回答已采纳
1回答
在Kedro中，我们可以对不同的节点进行流水线，并部分运行一些节点。当我们部分运行某些节点时，我们需要从某个节点中保存一些输入，以便在运行另一个节点时，它可以访问前一个节点生成的数据。但是，我们应该在哪个文件中编写这个代码- pipeline.py、run.py还是nodes.py？
例如，我试图在变量名“model_ path”下将dir路径直接保存到DataCatalog。
来自pipeline.py的片段：
# A mapping from a pipeline name to a ``Pipeline`` object.
def create_pipelines(**kwarg
浏览 2提问于2019-10-18得票数 4
回答已采纳
我想使用不同的输入运行一个kedro管道，并将结果保存在输出文件夹中，其中通过命令行提供输入路径和输出路径
我提出了使用kedro.config.TemplatedConfigLoader将新变量传递给jinja2模板编目的可能性，但通过这种方式，我只能手动定义钩子中的globals_dict变量，如kedro文档中所示。
理想情况下，我希望运行下面这样的代码：
kedro run --pipeline="my_pipeline" --input="path_to_input_1" --output="path_to_output_1"
kedr
浏览 6提问于2021-09-10得票数 0
你好，我正在使用kedro (一个管道工具)，并且希望在我推到我的github时使用github操作来触发kedro命令(kedro run)。
因为我有本地回购中的所有数据，所以我认为在本地机器上运行kedro命令是有意义的。所以我的问题是，是否有一种方法可以使用github操作触发本地操作？也许使用自我托管的跑步者？
浏览 5提问于2022-03-27得票数 0
2回答
我们正在努力为在Kedro中使用的数据建立正确的模型--我们使用的是推荐的Raw\Int\Prm\Ft\Mst模型，但是我们正在为一些概念而奋斗。
什么时候数据集是特性而不是主数据集？区别似乎很模糊..。
主数据集可以使用来自另一个主数据集的数据吗？
从INT层构建特性数据集是一种良好的实践吗？还是应该一直通过小学？
我理解数据建模没有硬性和快速的规则，但这些都是大的建模决策&任何关于Kedro建模的指导或最佳实践都会非常有用，我只能找到一个定义中的层的表。
如果有人能提供任何进一步的建议或博客\docs谈论Kedro数据建模，那将是很棒的！
浏览 6提问于2021-06-10得票数 2
回答已采纳
2回答
我在parameters.yml中使用嵌套参数，并希望使用kedro run CLI命令的运行时参数覆盖这些参数：
train:
batch_size: 32
train_ratio: 0.9
epochs: 5
以下几点似乎行不通：
kedro run --params train.batch_size:64,train.epochs:50
epoch和batch_size的值是来自parameters.yml的值。如何使用cli命令重写这些参数？
浏览 8提问于2020-08-04得票数 3
回答已采纳
2回答
我有一条很大的管道，需要几个小时才能运行。它的一小部分需要经常运行，我如何在不触发整个管道的情况下运行它？
浏览 4提问于2019-11-27得票数 5
回答已采纳
2回答
对kedro有问题。“register_pipelines”函数似乎没有运行或创建我要从中返回的默认管道。
错误是
(kedro-environment) C:\Users\cc667216\OneDrive\DCS_Pipeline\dcs_files>kedro run
2021-03-22 13:30:28,201 - kedro.framework.session.store - INFO - `read()` not implemented for `BaseSessionStore`. Assuming empty store.
fatal: not a git reposi
浏览 2提问于2021-03-22得票数 1
回答已采纳
我已经使用建立管道使用虹膜数据，并创建了一个车轮和鸡蛋文件使用"kedro包“。在此之后，我使用python创建了一个虚拟环境，并在那里安装了轮子和鸡蛋文件。我尝试从环境中的脚本文件夹和(exe文件)运行管道文件，但是它抛出的“找不到kedro.yml错误”。
如果这是传输项目和运行管道的正确方式，请您帮助我吗?如果不是，您能帮助我正确地部署管道并在新的环境中运行它们吗？
浏览 2提问于2020-05-04得票数 2
我们正在10多家公司之间部署一个数据联盟。Wi将为所有公司部署多个机器学习模型(一般是高级分析模型)，我们将对所有模型进行管理。我们正在寻找一种管理多个服务器、集群和数据科学管道的解决方案。我喜欢kedro，但不确定在使用kedro时管理所有这些的最佳选择是什么。
总之，我们正在寻找最好的解决方案来管理多个模型、任务和管道，在不同的服务器和可能的星火集群中。我们目前的选择是：
AWS作为我们的数据仓库和数据库，用于管理服务器、集群和任务。我不认为databricks的笔记本是构建管道和协同工作的好解决方案，所以我想将kedro连接到databricks (好吗？)使用databricks来
浏览 5提问于2020-11-20得票数 5
回答已采纳
1回答
我目前正在与kedro, version 0.15.4一起使用pipenv, version 2018.11.26。
目前，如果要使用Pipenv，我必须执行以下操作(对于本例，我希望该项目驻留在kedro-pipenv目录中)：
mkdir kedro-pipenv && cd kedro-pipenv --这是必需的，以便创建的virtualenv“绑定”到项目目录，这实际上意味着它的名称是基于目录名的，此时pipenv install kedro或pipenv shell命令是executed.Unfortunately，，Pipenv没有支持自定义virtualenv
浏览 0提问于2019-11-25得票数 2
我遵循了kedro pipelines教程，创建了所有需要的文件，并使用kedro run --node=preprocess_companies启动了kedro
它返回以下错误ValueError: Pipeline不包含名为'preprocess_companies‘的节点。确实试图找到解决方案，但没有成功。感谢您的帮助！
我使用以下文件3：
1) C:\Users\Name\tutorrr\src\tutorrr\pipelines\data_engineering\nodes.py
**import pandas as pd
def _is_true(x):
retur
浏览 2提问于2020-05-07得票数 0
我希望将Kedro内存数据集保存在azure中作为一个文件，并且仍然希望将它保存在内存中，因为我的管道将在稍后的管道中使用它。这在凯德罗有没有可能。我试图查看转换数据集，但看起来不可能。还有别的办法来解决这个问题吗？
浏览 3提问于2022-01-18得票数 0
回答已采纳
我想使用jupyter笔记本在基本env中运行kedro管道。我这样做的方式如下：
%reload_kedro --env=base
session.run(pipeline_name='dpfm1')
这样做，%reload_kedro命令将引发以下错误：
RuntimeError: Could not find the project configuration file 'pyproject.toml' in --env=base. If you have created
your project with Kedro version <0.17.
浏览 13提问于2022-10-07得票数 0
回答已采纳
目前，我使用的是kedro和kedro-viz。 我可以从catalog.yml中指定一个数据集层。 hoge:
type: MemoryDataSet
layer: raw 但我不知道如何使用parameters.yml step_size: 1
learning_rate: 0.01 如果不是用parameters.yml，而是用run.py，我想看看示例代码。
浏览 17提问于2020-08-26得票数 0
回答已采纳
我试图了解Kedro中的最佳方法是如何将一个节点中的火花数据转换为另一个节点所需的Pandas，而不需要创建冗余的转换步骤。
浏览 2提问于2019-11-11得票数 3
回答已采纳
我正在使用kedro.extras.datasets.pandas.SQLTableDataSet，并且希望使用pandas中的chunk_size参数。但是，在运行管道时，该表被视为生成器，而不是pd.dataframe()。
您将如何在管道中使用chunk_size？
我的目录：
table_name:
type: pandas.SQLTableDataSet
credentials: redshift
table_name : rs_table_name
layer: output
save_args:
if_exists: append
schema
浏览 13提问于2021-05-13得票数 0
我使用Kedro非常新，在我的conda环境中安装kedro之后，在尝试列出我的目录时会出现以下错误：
执行的命令：kedro catalog list
错误：
kedro.io.core.DataSetError:当解析DataSet df_medinfo_raw：Object ParquetDataSet的配置时，无法从kedro.extras.datasets.pandas加载异常。请参阅有关如何安装kedro.extras.datasets.pandas.ParquetDataSet相关依赖项的文档：
我安装了酮德洛槽，康达锻造：conda install -c conda-f
浏览 13提问于2022-01-15得票数 3
回答已采纳
我能够使用kedro run命令毫无问题地运行管道。不过，出于某种原因，我再也无法从朱庇特笔记本中访问我的上下文和目录了。当我运行kedro jupyter notebook并在选择" new“时使用我的项目名称启动一个新的(或现有的)笔记本时，我会得到以下错误：
context
NameError: name 'context' is not defined
catalog.list()
NameError: name 'catalog' is not defined
编辑：
在运行魔术命令%kedro_reload之后，我可以看到我的ProjectC
浏览 2提问于2021-02-02得票数 2
在MongoDB或其他文档数据库中使用kedro的最佳实践是什么？例如，MongoDB没有类似于SQL的查询语言。Python中的大多数Mongo“查询”(使用PyMongo)将如下所示：
from pymongo import MongoClient
client = MongoClient(...) // Credentials go here
posts = client.test_database.posts
posts.find_one({"author": "Mike"})
然后你会得到像这样的东西：
{u'_id': Obje
浏览 0提问于2019-11-20得票数 3
1回答
我想捆绑Python包kedro，它提供了一个命令行界面(kedro)。此外，我还想把Python包kedro-docker放到快照中。第二个包扩展了第一个包的命令行界面(kedro docker)。但是当我使用下面的snapcraft.yaml创建快照时，我只得到了第一个包的命令行界面： name: kedro
base: core18
version: latest
description: |
Kedro is a development workflow framework that implements software
engineering best-pract
浏览 15提问于2020-05-02得票数 0
回答已采纳
我知道我可以通过kedro_cli.py添加任何命令行界面选项。但我找不到如何更改动态加载的钩子。 我使用的是kedro-mlflow，它的特性是通过钩子提供的。有时我不想暂时登录MLFlow。 如果可能的话，请给我看一个ProjectContext代码的例子。
浏览 20提问于2020-10-22得票数 0
1回答
我必须测试我的kedro项目是否在github中工作，所以我创建了一个新的环境，然后：
git clone <my_project>
pip install kedro kedro[pandas] kedro-viz jupyter
kedro build-reqs
kedro install
安装失败，然后我重试几次(有时是2或3次)，然后下一次尝试就成功了。
编辑: python -V :Python3.7.10kedro--版本: kedro，版本0.17.3
我不能发布我的requirement.txt (主要是代码)，所以这里是我的requirement.in
浏览 6提问于2021-06-11得票数 2
回答已采纳
1回答
我想创建我自己的Kedro初学者。我试着复制熊猫的相关部分。我有一个cookiecutter.json文件，它具有我认为是适当的映射，并且我已经更改了repo和包目录名，以及对Kedro版本的任何引用，这样它们就可以使用cookie裁剪器了。
我能够用kedro new --starter=path/to/my/starter从我的初学者中生成一个新的项目。但是，新创建的项目使用项目、包和回购名称的默认值，而不提示我在终端中输入任何内容。
我是不是弄错了什么东西？如何创建一个启动程序，提示用户在创建新项目时覆盖默认值？
下面是我的初学者项目顶部目录中cookiecutter.json的内容：
浏览 5提问于2022-01-06得票数 0
回答已采纳
我正在用kedro做一些比较分析。
我正在使用quarto包，通过函数为quarto提供一个包装器。这个函数将以一个qmd文件作为输入，并在计算python块时从它生成一个html报告。
在四分之一的报告中，我有一些包含output_var1和output_var2评估的块，例如：
plot_function(output_var1)
plot_function(output_var2)
例如，output_var1和output_var2是熊猫的数据框架(可以是任何类型的数据)
在管道的末尾，我想使用管道的结果来计算我的报告，而不把它保存到数据目录中。
from quarto import
浏览 16提问于2022-10-17得票数 0
回答已采纳
我试着部署例子Kedro初学者项目(熊猫-虹膜)。我成功地在本地运行它(kedro run)，然后让kedro-docker安装，插入一个Docker，构建映像并将其推送到我的注册表。
不幸的是，kedro docker run和docker run myDockerID/iris_image都会产生相同的错误：
DataSetError: Failed while loading data from data set
CSVDataSet(filepath=/home/kedro/data/01_raw/iris.csv, load_args={},
protocol=file, save
浏览 3提问于2022-09-17得票数 0
1回答
在spark上寻找kedro+ airflow的实现。这个插件现在可以用于spark了吗？ 查看了PipelineX，但在spark上找不到相关的示例？
浏览 8提问于2020-08-14得票数 0
我想通过命令行控制kedro参数。
根据，kedro可以指定运行时参数如下：
kedro run --params key:value
> {'key': 'value'}
它起作用了。同样，我尝试指定列表参数，如下所示：
kedro run --params keys:['value1']
> {'keys': '[value1]'}
它不能工作，因为kedro 不是列表，而是str。可能，可能是相关的。
希望能提几件事让kedro评估像yaml这样的列表参数。
浏览 3提问于2020-06-20得票数 1
回答已采纳
我收到此错误：
DataSetError: Failed while loading data from data set SQLQueryDataSet(load_args={}, sql=select * from table)
当我运行时(在kedro jupyter笔记本中)：
%reload_kedro
c:\users\name.virtualenvs\pipenv_kedro\lib\site-packages\ipykernel\ipkernel.py:283:DeprecationWarning：should_run_async将来不会自动调用transform_cell。请
浏览 4提问于2021-04-22得票数 0
1回答
如何使用发电机与酮？
、、、
多亏了，我非常喜欢使用生成器来进行数据处理，以使内存消耗降到最低。现在我正在做我的第一个kedro项目，我的问题是如何在kedro中使用生成器。当我有一个生成生成器的节点，然后使用kedro run --node=example_node运行它时，我会得到以下错误：
DataSetError: Failed while saving data to data set MemoryDataSet().
can't pickle generator objects
在使用kedro时，我应该总是将所有数据加载到内存中吗？
浏览 5提问于2022-08-23得票数 1
回答已采纳
在kedro datacatalog中配置azure blob存储数据集时遇到错误。
我在我的catalog.yml中定义了如下数据集：
brand_dataset:
type: pandas.CSVDataSet
filepath: "abfs://container/my_file.csv"
credentials: my_creds
load_args:
sep:';'
尝试从ipython访问数据集时，会遇到以下错误
DataSetError:
unexpected unindent (core.py, line 160).
F
浏览 3提问于2021-11-25得票数 0
我有一个包含多个文件的目录，用于相同的数据格式(每天一个文件)。就像一个数据被分割成多个文件。
是否可以不指定每个文件而将所有文件传递给Kedro节点？所以它们都是根据跑步者的顺序或并行处理的？
浏览 6提问于2019-11-19得票数 4
我对凯德罗很陌生，我不知道我在这里问的问题是否对。
是否有可能在kedro上绘制x和y列表？
我正在运行带有mlflow的kedro管道。我有catalog.yaml，我记录度量和工件。
最终目标是：
kedro运行1#生成x11,2,3,4和y1=1,2,2,2 --这些数字只是例子
kedro 2# generate x21,2,3,4和y2=3,1,2,1 --这些数字只是例子
kedro 3# generate x21,2,3,4和y2=1,3,3,3 --这些数字只是例子
然后kedro mlflow ui
选择run1、run2和run3，然后单击“比较”。
在散点图上->能
浏览 4提问于2022-04-01得票数 0
我在S3存储桶中有多个文本文件，我可以读取和处理这些文件。因此，我在Kedro datacatalog中定义了PartitionedDataSet，如下所示： raw_data:
type: PartitionedDataSet
path: s3://reads/raw
dataset: pandas.CSVDataSet
load_args:
sep: "\t"
comment: "#" 此外，我实现了这个solution，通过包括亚马逊网络服务密钥在内的环境变量从凭证文件中获取所有秘密。 当我使用kedro run在本地运行
浏览 14提问于2020-09-22得票数 2
我是kedro的新手，我正在尝试运行太空飞行教程。我想运行完整的data_processing_pipeline 'dp'，并在数据帧中捕获输出。我在Jupyter Lab上运行它。我使用了以下命令: model_input_table =session.run(管道名称=‘dp’)或model_input_table =context.run(管道名称=‘dp’) 我甚至尝试运行特定的节点来捕获返回到变量中的输出。 似乎什么都不起作用！请帮帮我！
浏览 14提问于2021-10-08得票数 0
3回答
我创建了一个名为Foo的conda环境。激活这个环境之后，我用pip安装了Kedro，因为conda给了我冲突。即使我在Foo环境中，当我运行：
kedro jupyter lab
它从我的base环境中获取模块，而不是Foo环境。知道为什么会发生这种情况，以及如何改变我的笔记本所检测到的模块？
编辑
通过错误处理我的代码，我发现在\AppData\Roaming\jupyter\kernels\kedro_project\kernel.json上，它是从基本环境调用python，而不是从Foo环境调用。我手动更改了它，但是是否有一种模式自动设置\AppData\Roaming\jupyter
浏览 9提问于2022-05-17得票数 0
回答已采纳
是否有任何方法访问kedro管道环境名称？其实下面是我的问题。
我正在加载配置路径，如下所示
conf_paths = ["conf/base", "conf/local"]
conf_loader = ConfigLoader(conf_paths)
parameters = conf_loader.get("parameters*", "parameters*/**")
catalog = conf_loader.get("catalog*")
但是我没有像"conf/server"、
浏览 9提问于2021-12-14得票数 1
回答已采纳
2回答
我跟随，创建了所有需要的文件，用kedro run --node=preprocessing_data启动了kedro，但遇到了这样的错误消息：
ValueError: Pipeline does not contain nodes named ['preprocessing_data'].
如果我不带node参数运行kedro，我会收到
kedro.context.context.KedroContextError: Pipeline contains no nodes
文件的内容：
src/project/pipelines/data_engineering/nodes.p
浏览 7提问于2020-02-23得票数 4
回答已采纳
1回答
我一直在运行Kedro教程( hello world和spaceflight)，我想知道使用kedro进行数据并行化是否容易。想象一下，如果我有一个需要在数百万个文件中执行的节点。
我似乎有一个选项kedro run -p，但它只做任务并行化(正如这里所说的)。
感谢您的反馈
浏览 0提问于2019-11-20得票数 2
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM活动推荐
腾讯云开发者
