MCPcopy
hub / github.com/kubeflow/pipelines

github.com/kubeflow/pipelines @2.16.1 sqlite

repository ↗ · DeepWiki ↗ · release 2.16.1 ↗
24,509 symbols 72,363 edges 2,601 files 9,171 documented · 37%
README

Kubeflow Pipelines

Coverage Status SDK Documentation Status SDK Package version SDK Supported Python versions OpenSSF Best Practices Ask DeepWiki

Overview of the Kubeflow pipelines service

Kubeflow is a machine learning (ML) toolkit that is dedicated to making deployments of ML workflows on Kubernetes simple, portable, and scalable.

Kubeflow pipelines are reusable end-to-end ML workflows built using the Kubeflow Pipelines SDK.

The Kubeflow pipelines service has the following goals:

  • End to end orchestration: enabling and simplifying the orchestration of end to end machine learning pipelines
  • Easy experimentation: making it easy for you to try numerous ideas and techniques, and manage your various trials/experiments.
  • Easy re-use: enabling you to re-use components and pipelines to quickly cobble together end to end solutions, without having to re-build each time.

Installation

  • Kubeflow Pipelines can be installed as part of the Kubeflow Platform. Alternatively you can deploy Kubeflow Pipelines as a standalone service.

  • The Docker container runtime has been deprecated on Kubernetes 1.20+. Kubeflow Pipelines has switched to use Emissary Executor by default from Kubeflow Pipelines 1.8. Emissary executor is Container runtime agnostic, meaning you are able to run Kubeflow Pipelines on Kubernetes cluster with any Container runtimes.

Dependencies Compatibility Matrix

Dependency Versions
Argo Workflows v3.5, v3.7
MySQL v8

Documentation

Get started with your first pipeline and read further information in the Kubeflow Pipelines overview.

See the various ways you can use the Kubeflow Pipelines SDK.

See the Kubeflow Pipelines API doc for API specification.

Consult the Python SDK reference docs when writing pipelines using the Python SDK.

Deep Wiki

Check out our AI Powered repo documentation on DeepWiki.

:warning: Please note, this is AI generated and may not have completely accurate information.

Contributing to Kubeflow Pipelines

Before you start contributing to Kubeflow Pipelines, read the guidelines in How to Contribute. To learn how to build and deploy Kubeflow Pipelines from source code, read the developer guide.

Optional just command runner

For local developer convenience, this repository includes an optional just command runner at the repo root. It provides short aliases for existing make targets and does not replace any CI or release workflows.

To use it, install just and run, for example:

just           # list available recipes
just backend-test
just backend-images

Notes:

  • All just recipes are thin wrappers around existing make targets (for example, make -C backend/src/v2 test).
  • There is intentionally no generic just build or just test recipe; heavy or Docker-building flows are exposed only via explicitly named recipes such as backend-images.

Kubeflow Pipelines Community

Community Meeting

The Kubeflow Pipelines Community Meeting occurs every other Wed 10-11AM (PST).

Calendar Invite

Direct Meeting Link

Meeting notes

Slack

We also have a slack channel (#kubeflow-pipelines) on the Cloud Native Computing Foundation Slack workspace. You can find more details at https://www.kubeflow.org/docs/about/community/#kubeflow-slack-channels

Architecture

Details about the KFP Architecture can be found at Architecture.md

Blog posts

Acknowledgments

Kubeflow pipelines uses Argo Workflows by default under the hood to orchestrate Kubernetes resources. The Argo community has been very supportive and we are very grateful.

Extension points exported contracts — how you extend this code

ScheduledWorkflowNamespaceLister (Interface)
ScheduledWorkflowNamespaceLister helps list and get ScheduledWorkflows. [26 implementers]
backend/src/crd/pkg/client/listers/scheduledworkflow/v1beta1/scheduledworkflow.go
Template (Interface)
(no doc) [2 implementers]
frontend/src/third_party/mlmd/argo_template.ts
PartialArtifactRepositoriesValue (Interface)
PartialArtifactRepositoriesValue is used to deserialize the contents of the * artifact-repositories configmap.
frontend/server/workflow-helper.ts
ClientOption (FuncType)
ClientOption may be used to customize the behavior of Client methods.
backend/api/v1beta1/go_http_client/pipeline_client/pipeline_service/pipeline_service_client.go
BaseResource (Interface)
(no doc)
frontend/mock-backend/mock-api-middleware.ts
ScheduledWorkflowInterface (Interface)
ScheduledWorkflowInterface has methods to work with ScheduledWorkflow resources. [6 implementers]
backend/src/crd/pkg/client/clientset/versioned/typed/scheduledworkflow/v1beta1/scheduledworkflow.go
LineageViewProps (Interface)
(no doc) [1 implementers]
frontend/src/mlmd/LineageView.tsx
ArtifactsQueryStrings (Interface)
* ArtifactsQueryStrings describes the expected query strings key value pairs * in the artifact request object.
frontend/server/handlers/artifacts.ts

Core symbols most depended-on inside this repo

Pointer
called by 776
backend/api/v1beta1/go_http_client/job_model/job_mode.go
get
called by 684
frontend/src/lib/URLParser.ts
Marshal
called by 441
backend/src/v2/metadata/client.go
Error
called by 406
backend/src/agent/persistence/client/artifactclient/client.go
NewInternalServerError
called by 372
backend/src/common/util/error.go
Close
called by 372
backend/src/apiserver/client_manager/client_manager.go
get
called by 347
backend/src/apiserver/visualization/server.py
flushPromises
called by 315
frontend/src/TestUtils.ts

Shape

Method 14,067
Function 6,319
Class 1,656
Struct 1,324
Interface 782
Route 147
Enum 104
TypeAlias 91
FuncType 19

Languages

Go57%
Python29%
TypeScript14%

Modules by API surface

third_party/ml-metadata/go/ml_metadata/metadata_store_service.pb.go937 symbols
api/v2alpha1/go/pipelinespec/pipeline_spec.pb.go766 symbols
third_party/ml-metadata/go/ml_metadata/metadata_store.pb.go598 symbols
sdk/python/kfp/compiler/compiler_test.py369 symbols
third_party/ml-metadata/go/ml_metadata/metadata_store_service_grpc.pb.go270 symbols
kubernetes_platform/go/kubernetesplatform/kubernetes_executor_config.pb.go261 symbols
frontend/src/third_party/mlmd/generated/ml_metadata/proto/metadata_store_service_pb.d.ts227 symbols
backend/api/v2beta1/go_client/run.pb.go208 symbols
backend/api/v1beta1/go_client/run.pb.go169 symbols
backend/api/v1beta1/go_client/pipeline.pb.go159 symbols
backend/api/v2beta1/go_client/recurring_run.pb.go148 symbols
backend/api/v2beta1/go_client/pipeline.pb.go142 symbols

Dependencies from manifests, versioned

cel.dev/exprv0.24.0 · 1×
cloud.google.com/gov0.121.2 · 1×
cloud.google.com/go/authv0.16.1 · 1×
cloud.google.com/go/auth/oauth2adaptv0.2.8 · 1×
cloud.google.com/go/computev1.21.0 · 1×
cloud.google.com/go/compute/metadatav0.7.0 · 1×
cloud.google.com/go/monitoringv1.24.2 · 1×
cloud.google.com/go/storagev1.55.0 · 1×
dario.cat/mergov1.0.2 · 1×
filippo.io/edwards25519v1.1.0 · 1×
github.com/GoogleCloudPlatform/opentelemetry-operations-go/detectors/gcpv1.28.0 · 1×

Datastores touched

(mysql)Database · 1 repos

For agents

$ claude mcp add pipelines \
  -- python -m otcore.mcp_server <graph>

⬇ download graph artifact