airflow - Airflow で動的に作成されたタスク間の依存関係を作成する方法

Question

以下のコードを使用して動的タスクを作成しています。これらの動的に作成されたタスクへの依存関係を作成したいと考えています。たとえば、runStep_0 は runStep_1 などに依存する必要があります。

for i in range(4):

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

Answer 1

ついに抜け道を見つけた。各反復中に各タスクをリストに追加し、リストから参照します。