如何在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更新變量。