Pipeline Parameters
Passing data between pipeline components
The kfp.dsl.PipelineParam
classrepresents a data type that you can pass between pipeline components.
You can use a PipelineParam
object as an argument in your pipeline function.The object is then a pipeline parameter that shows up in Kubeflow Pipelines UI.A PipelineParam
can also represent an intermediate value that you pass betweencomponents.
The following code sample shows how to use PipelineParam
objects asarguments in a pipeline function:
@kfp.dsl.pipeline(
name='My pipeline',
description='My machine learning pipeline'
)
def my_pipeline(
my_num = dsl.PipelineParam(name='num-foos', value=1000),
my_name = dsl.PipelineParam(name='my-name', value='some text'),
my_url = dsl.PipelineParam(name='foo-url', value='http://example.com')):
...
The DSL supports auto-conversion from string to PipelineParam
. You cantherefore write the same function like this:
@kfp.dsl.pipeline(
name='My pipeline',
description='My machine learning pipeline'
)
def my_pipeline(
my_num='1000',
my_name='some text',
my_url='http://example.com'):
...
See more about PipelineParam
objects in the guide to building acomponent.