Compare Airflow and Kubeflow for ML training pipelines

What's really being asked

The interviewer wants to see if you understand that workflow orchestration is not one-size-fits-all. They are testing whether you can decompose an ML pipeline into stages and match each stage to the right platform based on data movement patterns, compute requirements, and team expertise. Specifically, they care if you recognize Airflow as a general-purpose scheduler with deep data integration versus Kubeflow as a Kubernetes-native ML platform with primitives for distributed training and experiment management.

The full answer

First, contrast core architecture. Airflow uses Python DAGs with operators to move data between systems, making it ideal for preprocessing and ETL because it integrates easily with warehouses, lakes, and Spark. Kubeflow Pipelines run containerized steps on Kubernetes, which enforces reproducibility and simplifies scaling out distributed training or GPU workloads. Second, discuss operational concerns. Airflow requires you to manage training artifacts, metrics, and model versioning yourself or through external tools. Kubeflow provides native experiment tracking, hyperparameter tuning via Katib, and model serving via KServe, reducing glue code. Third, mention resource management. Airflow workers are typically CPU-bound and scheduling GPU jobs can be awkward without custom executors. Kubeflow leverages Kubernetes resource quotas, node selectors, and autoscaling for ML-specific hardware. Fourth, acknowledge hybrid reality. Many teams use Airflow for data ingestion and feature engineering, then trigger Kubeflow pipelines for training and evaluation, or use Airflow to orchestrate Kubeflow jobs via KubernetesPodOperator.

The mistakes people make

A red flag is claiming Airflow cannot do ML or Kubeflow cannot do ETL. Both can, but suboptimally. Another mistake is ignoring the Kubernetes requirement. Kubeflow demands K8s expertise and cluster management overhead that may be unjustified for small teams. Conversely, suggesting Airflow for large-scale distributed GPU training without addressing executor limitations shows inexperience. Finally, failing to mention artifact lineage or reproducibility marks you as thinking only about job scheduling rather than the full ML lifecycle.

What usually comes next

How would you pass large datasets between Airflow tasks without hitting memory limits? When would you use Airflow's KubernetesPodOperator versus a native Kubeflow Pipeline? How do you handle experiment tracking if you stay on Airflow? Describe how you would migrate an existing Airflow DAG to Kubeflow. What is your strategy for testing and versioning container images in Kubeflow?

A concrete example

Imagine a daily recommendation model pipeline. You use Airflow to orchestrate Spark jobs that preprocess user click logs in S3 and write feature stores. Once features are ready, Airflow triggers a Kubeflow Pipeline that launches a distributed TensorFlow training job on four GPUs using K8s autoscaling. Kubeflow handles hyperparameter tuning, captures metrics in its experiment UI, and pushes the validated model to a model registry. Airflow then resumes to run batch inference on the new model and export results back to the data warehouse. This hybrid pattern plays to each tool's strengths.