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

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