gpt4 book ai didi

python - AIRFLOW - 从运算符(operator)列表中设置关系

转载 作者:行者123 更新时间:2023-12-02 19:14:00 29 4
gpt4 key购买 nike

我有一个运算符列表,它们被附加到 for 循环中的列表中。我想为我的 DAG 设置一个关系,其中每个任务都按列表的顺序设置在下游。例如

task_list = []
for operator in operator_array:
task = operator
task_list.append(task)

# theoretically I would want something like this:

some_other_operator >> task_list[0] >> task_list[1] >> task_list[2] and so on and so forth for however long the length of the list is

谢谢

最佳答案

为此创建了一个辅助函数,它的性能比接受的答案要高得多

参见airflow.utils.helpers模块

from airflow.utils.helpers import chain

chain(*task_list)

关于python - AIRFLOW - 从运算符(operator)列表中设置关系,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/63924188/

29 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com