小编Sti*_*enb的帖子

如何在 Airflow DAG 中循环顺序运行任务?

假设我有一个示例 DAG 的片段:

variables = ['first', 'second', 'third']

def run_dag_task(variable):
  task = dag_task(variable)
  return task

for variable in variables:
  run_dag_task(variable)
Run Code Online (Sandbox Code Playgroud)

此代码将为三个变量并行运行三个任务。现在,假设我希望在开始第二个任务之前完成第一个任务,并在开始第三个任务之前完成第二个任务。我将如何用循环来做到这一点?那可能吗?

python airflow

3
推荐指数
1
解决办法
2万
查看次数

标签 统计

airflow ×1

python ×1