kedro/framework/cli/pipeline.py
def create_pipeline(name, skip_config, env):
    """Create a new modular pipeline by providing the new pipeline name as an argument."""
    try:
        context = load_context(Path.cwd(), env=env)
    except Exception as err:  # pylint: disable=broad-except
        _handle_exception(
            f"Unable to load Kedro context with environment `{env}`. "
            f"Make sure it exists in the project configuration.\nError: {err}"
        )

    package_dir = _get_project_package_dir(context)
    output_dir = package_dir / "pipelines"

    result_path = _create_pipeline(name, context.project_version, output_dir)
    _copy_pipeline_tests(name, result_path, package_dir)
    _copy_pipeline_configs(name, result_path, context, skip_config, env=env)
    click.secho(f"\nPipeline `{name}` was successfully created.\n", fg="green")

    click.secho(
        f"To be able to run the pipeline `{name}`, you will need to add it "
        f"to `create_pipelines()` in `{package_dir / 'pipeline.py'}`.",
        fg="yellow",
    )
Create a new modular pipeline by providing the new pipeline name as an argument.
Create a new modular pipeline by providing the new pipeline name as an argument.
Create a new modular pipeline by providing the new pipeline name as an argument .
def create_pipeline(name, skip_config, env):
    try:
        context = load_context(Path.cwd(), env=env)
    except Exception as err:  
        _handle_exception(
            f"Unable to load Kedro context with environment `{env}`. "
            f"Make sure it exists in the project configuration.\nError: {err}"
        )
    package_dir = _get_project_package_dir(context)
    output_dir = package_dir / "pipelines"
    result_path = _create_pipeline(name, context.project_version, output_dir)
    _copy_pipeline_tests(name, result_path, package_dir)
    _copy_pipeline_configs(name, result_path, context, skip_config, env=env)
    click.secho(f"\nPipeline `{name}` was successfully created.\n", fg="green")
    click.secho(
        f"To be able to run the pipeline `{name}`, you will need to add it "
        f"to `create_pipelines()` in `{package_dir / 'pipeline.py'}`.",
        fg="yellow",
    )
def create_pipeline ( name , skip_config , env ) : try : context = load_context ( Path . cwd ( ) , env = env ) except Exception as err : _handle_exception ( f"Unable to load Kedro context with environment `{env}`. " f"Make sure it exists in the project configuration.\nError: {err}" ) package_dir = _get_project_package_dir ( context ) output_dir = package_dir / "pipelines" result_path = _create_pipeline ( name , context . project_version , output_dir ) _copy_pipeline_tests ( name , result_path , package_dir ) _copy_pipeline_configs ( name , result_path , context , skip_config , env = env ) click . secho ( f"\nPipeline `{name}` was successfully created.\n" , fg = "green" ) click . secho ( f"To be able to run the pipeline `{name}`, you will need to add it " f"to `create_pipelines()` in `{package_dir / 'pipeline.py'}`." , fg = "yellow" , )
Create a new modular pipeline by providing the new pipeline name as an argument.
Create a new modular pipeline by providing the new pipeline name as an argument .
"""Create a new modular pipeline by providing the new pipeline name as an argument.""" # pylint: disable=broad-except
name
skip_config
env