如何设置airflow DAG概念调度
how set airflow DAG Concept scheduling
我正在尝试一些气流 DAG 计划。
我按照下面的代码安排了。
Task1 >> [Task2, Task3] >> Task4
然后，当完成 task2 和 task3 时，我预计 运行 Task4 一次。
但是..我认为...任务 4 运行 两次。
（任务 1 -> 任务 2 -> 任务 4）和（任务 1 -> 任务 3 -> 任务 4）
原因是..我看到了气流 DAG 树视图。
如何设置运行task4只执行一次？
Airflow 中的树视图 UI 显示了 DAG 中从根到叶的所有不同的 b运行 分支。根据您提供的屏幕截图，有 2 个 b运行ches:
- print_date >> 睡觉 >> print_date_1
- print_date >> 模板化 >> print_date_1
这并不意味着print_date_1任务运行两次。要查看实际的 DAG，请查看 Graph View（就在 Tree View 按钮的右侧）。您应该看到每个任务只出现一次。
您可能会发现 this guide 有助于理解 Airflow UI。
我正在尝试一些气流 DAG 计划。
我按照下面的代码安排了。
Task1 >> [Task2, Task3] >> Task4
然后，当完成 task2 和 task3 时，我预计 运行 Task4 一次。
但是..我认为...任务 4 运行 两次。
（任务 1 -> 任务 2 -> 任务 4）和（任务 1 -> 任务 3 -> 任务 4）
原因是..我看到了气流 DAG 树视图。
如何设置运行task4只执行一次？
Airflow 中的树视图 UI 显示了 DAG 中从根到叶的所有不同的 b运行 分支。根据您提供的屏幕截图，有 2 个 b运行ches:
- print_date >> 睡觉 >> print_date_1
- print_date >> 模板化 >> print_date_1
这并不意味着print_date_1任务运行两次。要查看实际的 DAG，请查看 Graph View（就在 Tree View 按钮的右侧）。您应该看到每个任务只出现一次。
您可能会发现 this guide 有助于理解 Airflow UI。