Airflow 2.5.0获取upstream_task_ids及筛选下游task_ids方法咨询

获取上游任务ID #

在Airflow 2.5.0中，BaseOperator.upstream_task_ids属性已被移除，可通过以下方式替代：

• 使用官方提供的get_upstream_task_ids()方法直接获取上游任务ID集合：

  upstream_task_ids = your_task.get_upstream_task_ids()
  

• 遍历upstream_list（存储上游任务实例的列表）提取ID：

  upstream_task_ids = [task.task_id for task in your_task.upstream_list]
  

获取下游任务ID #

要筛选得到当前任务的下游任务ID，可使用：

• get_downstream_task_ids()方法直接获取：

  downstream_task_ids = your_task.get_downstream_task_ids()
  

• 遍历downstream_list提取ID：

  downstream_task_ids = [task.task_id for task in your_task.downstream_list]
  

背景说明 #

Airflow 2.3及后续版本对任务依赖相关的API进行了重构，将原有的直接属性访问替换为封装后的方法，以此提升API稳定性并减少内部实现变更带来的兼容性问题。

内容的提问来源于stack exchange，提问作者andilabs