如何在Airflow中动态创建的任务之间创建依赖关系

Question

我正在使用下面的代码创建动态任务。我想创建这些动态创建的任务的依赖关系。对于e.g，runStep_0应该依赖于runStep_1等

for i in range(4): 

task = BashOperator(
    task_id='runstep_' + str(i), 
    bash_command=cmd 
    dag=dag) 

Answer 1

终于找到了一条出路。在每次迭代中将每个任务添加到列表中，并从列表中引用它。

Answer 2

在第一次迭代的循环内保存当前任务到previous_task变量。

第一次迭代后，只需设置task.set_upstream（previous_task）并使用previous_task = task更新变量。