我在KubernetesPodOperator上运行命令时遇到了问题,在DAG运行时会对整个命令进行评估。 我在DAG运行时生成命令,因为命令的一些参数取决于用户传递的参数。正如我从文档中读到的,KubernetesPodOperator需要字符串列表或jinja模板列表: :param arguments: arguments of the entrypoint.我有PythonOperator,它生成命令并将其推送到XCOM和KubernetesPodOperator,在这两个命令的参数中,我传递由PythonOperator生
遵循We're All Using Airflow Wrong中概述的最佳实践,我将DAG编写为一系列KubernetesPodOperator,它们运行非常简单的Python函数作为Docker映像的入口点但是从the KubernetesPodOperator's documentation来看,Kubernetes运算符似乎没有provide_context所做的事情的参数。我最好的猜测是,您可以使用arguments命令传入一个日期范围,因为它是模板化的,所以您可以像这样引用它: my_pod_operator = Kub