ChainYo
02/09/2022, 9:31 PMpython
@click.command()
@click.option("-p", "--pipeline", "pipeline_name", default=None)
@click.option("--env", "-e", type=dict, default=None)
@click.option("--params", type=dict, default=None)
def build_and_register_flow(pipeline_name, env, params):
"""Register a Kedro pipeline as a Prefect flow."""
project_path = Path.cwd()
metadata = bootstrap_project(project_path)
session = KedroSession.create(project_path=project_path, env=env, extra_params=params)