Я не совсем уверен, какую ошибку вы получаете. Если вы буквально пытаетесь сделать from .nodes import CleanData.function1
, это не сработает. Импорт не работает так в Python. Если вы сделаете что-то вроде этого:
nodes.py
имеет:
class CleanData:
def clean(arg1):
pass
и pipeline.py
имеет:
from kedro.pipeline import Pipeline, node
from .nodes import CleanData
def create_pipeline(**kwargs):
return Pipeline(
[
node(
CleanData.clean,
"example_iris_data",
None,
)
]
)
, которое должно работать.