Hello friends, I am using kedro 0.18.4 with python 3.7 When running this pipeline with the 'kedro run' command, I get this error message: 'TypeError: pipeline() got an unexpected keyword argument 'tags_hierarchy' anyone have any idea how to fix this?

from kedro.pipeline import Pipeline, node, pipeline
from .nodes import medium_posts_extract_file, medium_posts_transform_file, medium_posts_upload_transformed_file_to_gcp, medium_posts_persist_file_in_gcp, delete_files
from datetime import datetime

timestamp = datetime.now().strftime("%Y-%m-%d_%H-%M-%S")
#Defino los nodos dentro del pipeline y el orden de ejecución. Cada nodo puede tener 1 o mas funciones (definidas en nodes.py)
def create_pipeline(**kwargs) -> Pipeline:
    return pipeline(
        [
            node( 
                func=medium_posts_extract_file,
                inputs=None,
                outputs="medium_posts_raw_file",
                name="medium_posts_extract_file_node",
                tags=["extract"]
            ),
            node(
                func=medium_posts_transform_file,
                inputs="medium_posts_raw_file",
                outputs="medium_posts_transformed_file",
                name="medium_posts_transform_file_node",
                tags=["transform"]
            ),
            node(
                func=medium_posts_upload_transformed_file_to_gcp,
                inputs="medium_posts_transformed_file",
                outputs=None,
                name="medium_posts_upload_transformed_file_to_gcp_node",
                tags=["upload"]
            ),
            node(
                func=medium_posts_persist_file_in_gcp,
                inputs="medium_posts_raw_file",
                outputs=None,
                name="medium_posts_persist_file_in_gcp_node",
                tags=["persist"]
            ),
            node(
                func=delete_files,
                inputs="medium_posts_transformed_file",
                outputs=None,
                name="delete_files_node",
                tags=["delete"]
            )
        ],
        tags_hierarchy={
            "extract": [],
            "transform": ["extract"],
            "upload": ["transform"],
            "persist": ["upload"],
            "delete": ["persist"]
        }
    )

you have this in the

pipeline

constructor

tags_hierarchy={
            "extract": [],
            "transform": ["extract"],
            "upload": ["transform"],
            "persist": ["upload"],
            "delete": ["persist"]
        }

that’s not expected by Kedro unless you’ve modified it

Yes, i modified it because i need that specific order for the nodes to excecute

the way to do that is to pass inputs/outputs explicitly in the order you need it

hmmm, so if i'm understanding correctly. The inputs/outputs is what determines the excecution order of the nodes in the pipeline?

yup

ok, thank you very much for your help.

I'll take a look at it. Thank you

so you need an input, again you don’t need to use it for anything

and that input has to be declared in the catalog.yml?

the very first one does, but after that it can simply be an ephemeral output of another node