ref: https://nikkie-ftnext.hatenablog.com/entry/upload-kfp-compile-yaml-to-vertex-ai-pipelines-first-step

hello_world_kfp2_mlops_study39.py

# https://speakerdeck.com/asei/kubeflow-pipelines-v2-debian-waruji-jie-xue-xi-paipurainkai-fa?slide=10
from kfp import compiler, dsl


@dsl.component(base_image="python:3.9")
def hello_world(text: str) -> str:
    print(text)
    return text


@dsl.pipeline(
    name="intro-pipeline",
    description="A simple intro pipeline",
    pipeline_root="gs://mlops-study-hello-world",  # GCSにバケットを作って指定
)
def pipeline(text: str = "hi there"):
    first_task = hello_world(text=text)
    second_task = hello_world(text=first_task.output)


if __name__ == "__main__":
    compiler.Compiler().compile(
        pipeline_func=pipeline, package_path="intro_pipeline.yaml"
    )