python - Airflow DAG - 启动 kubernetes 作业

Question

使用气流 2.0

可以午餐 Kubernetes Job 吗？
作业在 yaml 文件中定义。例如

apiVersion: batch/v1
kind: Job 

有一个KubernetesPodOperator可以在 DAG 文件中使用，但似乎不能用于午餐 a Job.

标签： pythonairflow

Answer 1

看起来有人确实写了一个 KubernetesJobOperator。你可以在这里和这里看到。

我不确定您为什么要这样做，但这是作者的推理：