kedro/framework/cli/pipeline.py
def describe_pipeline(name, env):
    """Describe a pipeline by providing the pipeline name as an argument."""
    context = load_context(Path.cwd(), env=env)
    pipeline_obj = context.pipelines.get(name)
    if not pipeline_obj:
        existing_pipelines = ", ".join(sorted(context.pipelines.keys()))
        raise KedroCliError(
            f"`{name}` pipeline not found. Existing pipelines: [{existing_pipelines}]"
        )

    result = {
        "Nodes": [
            f"{node.short_name} ({node._func_name})"  # pylint: disable=protected-access
            for node in pipeline_obj.nodes
        ]
    }

    click.echo(yaml.dump(result))
Describe a pipeline by providing the pipeline name as an argument.
Describe a pipeline by providing the pipeline name as an argument.
Describe a pipeline by providing the pipeline name as an argument .
def describe_pipeline(name, env):
    context = load_context(Path.cwd(), env=env)
    pipeline_obj = context.pipelines.get(name)
    if not pipeline_obj:
        existing_pipelines = ", ".join(sorted(context.pipelines.keys()))
        raise KedroCliError(
            f"`{name}` pipeline not found. Existing pipelines: [{existing_pipelines}]"
        )
    result = {
        "Nodes": [
            f"{node.short_name} ({node._func_name})"  
            for node in pipeline_obj.nodes
        ]
    }
    click.echo(yaml.dump(result))
def describe_pipeline ( name , env ) : context = load_context ( Path . cwd ( ) , env = env ) pipeline_obj = context . pipelines . get ( name ) if not pipeline_obj : existing_pipelines = ", " . join ( sorted ( context . pipelines . keys ( ) ) ) raise KedroCliError ( f"`{name}` pipeline not found. Existing pipelines: [{existing_pipelines}]" ) result = { "Nodes" : [ f"{node.short_name} ({node._func_name})" for node in pipeline_obj . nodes ] } click . echo ( yaml . dump ( result ) )
Describe a pipeline by providing the pipeline name as an argument.
Describe a pipeline by providing the pipeline name as an argument .
"""Describe a pipeline by providing the pipeline name as an argument.""" # pylint: disable=protected-access
name
env