Airflow-无法在Kubernetes Pod Operator任务中为资源使用jinja模板



Airflow-无法在Kubernetes Pod Operator任务中为资源使用jinja模板。可以使用jinja模板作为环境变量,但不能用于指定CPU和内存的资源(请求和限制(。

之所以会发生这种情况,是因为resources不是模板化字段(请参阅源代码(。您仍然可以通过创建一个自定义操作符来获得您想要的功能:

from airflow.providers.cncf.kubernetes.operators.kubernetes_pod import KubernetesPodOperator
class MyKubernetesPodOperator(KubernetesPodOperator):
template_fields = KubernetesPodOperator.template_fields + ('resources',)

现在在MyKubernetesPodOperator中,resources参数是模板化的,您可以使用Jinja语法

最新更新