如何解决AIRFLOW-从操作员列表中设置关系
我有一个运算符列表,这些运算符已附加到for循环的列表中。我想为DAG设置一个关系,其中每个任务都按照列表的顺序设置在下游。例如
<script type="text/javascript" src="~/Scripts/"></script> <!-- broken -->
<script type="text/javascript" src="~/Scripts/<filename>.js"></script>
谢谢
解决方法
对于名为task_list
的任务列表,您可以执行以下操作:
some_other_operator >> task_list[0]
for i in range(len(task_list) - 1):
task_list[i] >> task_list[i + 1]
,
为此创建了一个辅助函数,其性能要比接受的答案好得多
from airflow.utils.helpers import chain
chain(*task_list)
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。