如何通过模板将列表传递给气流？

Question

我有一个基于 BaseOperator 的气流算子，它的字段之一是库。此字段获取可能需要安装以运行任务中的代码的 python 包的列表。

我希望能够通过模板变量传递该列表，但没有运气。

我尝试将列表作为字符串传递并使用 list(eval('{{ variable_name }}')) 将其分配给库的值，但这无法部署，因为 python 不知道 variable_name 是什么。

然后我尝试将数据作为列表传递并将“{{ variable_name }}”分配给库，但这导致 dag 运行失败，因为它需要一个对象并得到一个字符串。

有没有办法通过模板将这个列表对象传递给 dag？

Answer 1

目前不支持，合并https://github.com/apache/airflow/pull/14603后会支持。