>> 在 Airflow 中的多个应用？

Question

假设我有这样的 Airflow 任务：

apple_task = DummyOperator(
  task_id='apple'
)

banana_task = DummyOperator(
  task_id='banana'
)

cherry_task = DummyOperator(
  task_id='cherry'
)

apple_task >> cherry_task
banana_task >> cherry_task

>>的重复应用是堆叠还是替换前一个？

图形会是什么样子？

---

气流2.2.2

Answer 1

它们叠加，如 apple_task 和 banana_task 将并行 运行，两者都必须继承 运行 cherry_task.

相当于[apple_task, banana_task] >> cherry_task.

调度器解析DAG（默认每30s），读取DAG并构建图。像您一样指定任务依赖项的一个优点是，您可以在解析时动态创建任务 - 因为它们只是 python objects.

DAG 文档页面在任务依赖项标题下有更多示例 here and the control flow heading here。