如何创建Mwaa/airflow动态顺序任务

Question

我需要创建一个动态 mwaa/airflow，它需要根据任务列表动态创建顺序任务（不是动态任务映射）。

example1 : 
Task list =["task1","task2","task3"]
output = start>>task1>>task2>>task3>>end

example2 :
tasklist =["task1","task2"]
output=start>>task1>>task2>>end

感谢任何人都可以提供指导

Answer 1

最直接的方法是使用内置的

chain()

函数，它为您创建顺序任务依赖关系以及列表解包。

from airflow.models.baseoperator import chain

task_list = ["task1","task2","task3"]

chain(start, *task_list, end)