kfp package

kfp.run_pipeline_func_on_cluster(pipeline_func: Callable, arguments: Mapping[str, str], run_name: str = None, experiment_name: str = None, kfp_client: kfp._client.Client = None, pipeline_conf: kfp.dsl._pipeline.PipelineConf = None)[source]

Runs pipeline on KFP-enabled Kubernetes cluster. This command compiles the pipeline function, creates or gets an experiment and submits the pipeline for execution.

Parameters:
  • pipeline_func – A function that describes a pipeline by calling components and composing them into execution graph.
  • arguments – Arguments to the pipeline function provided as a dict.
  • run_name – Optional. Name of the run to be shown in the UI.
  • experiment_name – Optional. Name of the experiment to add the run to.
  • kfp_client – Optional. An instance of kfp.Client configured for the desired KFP cluster.
  • pipeline_conf – Optional. kfp.dsl.PipelineConf instance. Can specify op transforms, image pull secrets and other pipeline-level configuration options.ta