Beginner

Introduction to KubeFlow Pipelines

Understand what KubeFlow Pipelines is, its architecture, how it orchestrates ML workflows on Kubernetes, and where it fits in the modern MLOps ecosystem.

What is KubeFlow Pipelines?

KubeFlow Pipelines (KFP) is a platform for building and deploying portable, scalable machine learning workflows based on containers. It provides a Python SDK for defining pipelines, a UI for managing and tracking experiments, and an execution engine that runs workflows on Kubernetes.

KFP is part of the broader KubeFlow ecosystem, but it can also be deployed standalone for teams that only need pipeline orchestration.

💡
KFP v2: This course covers KubeFlow Pipelines v2 (KFP SDK 2.x), which uses a simplified Python-native API with decorators, improved type checking, and better artifact management compared to v1.

Architecture Overview

KubeFlow Pipelines consists of several key components:

💻

Pipeline SDK

Python library for defining pipelines as directed acyclic graphs (DAGs) of containerized steps using decorators and type hints.

Pipeline Service

REST API server that stores pipeline definitions, manages runs, and serves the web UI for experiment tracking.

📊

Execution Engine

Argo Workflows (v1) or Kubernetes-native controller (v2) that orchestrates container execution on the cluster.

🗃

Artifact Store

Object storage (MinIO, GCS, S3) for pipeline artifacts including datasets, models, metrics, and visualizations.

Why KubeFlow Pipelines?

KFP solves critical challenges in ML workflows:

  • Reproducibility: Every pipeline run is recorded with its parameters, code versions, and outputs, making experiments fully reproducible.
  • Portability: Pipelines run on any Kubernetes cluster - on-premises, GKE, EKS, or AKS - without modification.
  • Scalability: Each pipeline step runs in its own container and can request specific resources (GPUs, memory, storage).
  • Reusability: Components can be shared across pipelines and teams, reducing duplication and ensuring consistency.
  • Automation: Pipelines can be triggered by schedules, events, or CI/CD systems for continuous training.

KFP vs Other Orchestrators

FeatureKubeFlow PipelinesApache AirflowPrefectMLflow
ML-focused✓ NativeGeneral purposeGeneral purpose✓ Native
Kubernetes-nativeOptionalOptionalOptional
Container isolation✓ Per step✓ Per taskOptionalOptional
Experiment tracking✓ Built-inLimitedLimited✓ Core feature
Artifact management✓ NativeLimitedLimited✓ Native
GPU support✓ NativeVia K8s executorVia K8sVia K8s
Prerequisites: Basic Python programming, familiarity with Kubernetes concepts, and understanding of ML workflows (data prep, training, evaluation). No prior KubeFlow experience required.

Ready to Go Deeper?

Live instructor-led courses from our partners. Affiliate disclosure.