pipelines/components/contrib/kfp/Run_component/_samples/sample_pipeline.py

21 lines
687 B
Python

from kfp import components
kfp_endpoint = None
run_component_or_pipeline_op = components.load_component_from_url('https://raw.githubusercontent.com/kubeflow/pipelines/2d13b358690c761f64e5b59b70624de8f1f52a29/components/kfp/Run_component/component.yaml')
def my_pipeline():
run_component_or_pipeline_op(
component_url='https://raw.githubusercontent.com/kubeflow/pipelines/68a367de3d1cc435637b0b4e78dcb42600fbbc37/components/basics/Calculate_hash/component.yaml',
arguments=dict(
data='Hello world',
),
)
if __name__ == '__main__':
import kfp
kfp.Client(host=kfp_endpoint).create_run_from_pipeline_func(my_pipeline, arguments={})