Airflow - 任务的下游任务列表

Question

请问有没有列出一个任务的所有下游任务的airflow命令。例如，一个 dag 中有 4 个任务 - dummy1 > dummy2 > dummy3 > dummy4。我需要 dummy2 的所有下游任务列表，输出应该是 dummy3 和 dummy4。如果有一个命令，那么如果一个任务有很多下游任务并且只对下游任务执行手动操作，它将有所帮助。

Dag - dummy1 > dummy2 > dummy3 > dummy4

输出：（dummy2 的下游任务列表）

虚拟3 虚拟 4

Answer 1

没有用于此的 CLI 命令，但它是 Python 中的一个单行命令。

假设您的 DAG 脚本名称是 a_dag.py 并且 DAG 对象由变量 dag.

引用

然后你可以在终端中做这样的事情：

$ cd airflow/dags 

$ ls
a_dag.py

$ python
Python 3.8.2 ...
>>> from a_dag import dag
>>> dag.get_task('dummy2').get_flat_relative_ids()
{'dummy3', 'dummy4'}