Apache Airflow中资产调度依赖导致的DAG页面渲染问题分析

问题背景

在Apache Airflow 3.0.0版本中，当使用@asset装饰器定义两个相互依赖的数据资产时，DAG页面会出现渲染错误。具体表现为页面无法正常加载，控制台报错"Cannot read properties of undefined (reading '0')"，但值得注意的是，实际的DAG执行逻辑却能够正常工作。

问题复现条件

该问题会在以下场景中出现：

1. 定义两个使用@asset装饰器的函数
2. 下游资产直接引用上游资产作为调度依赖（不使用列表形式）
3. 在Web UI中尝试查看DAG页面

示例代码：

@asset(schedule="@daily") 
def test_asset(): 
    pass

@asset(schedule=test_asset)  # 直接引用上游资产
def test_asset_2():
    pass

技术原因分析

问题的根源在于Airflow前端对资产调度表达式的解析逻辑存在缺陷。在Airflow 3.0.0中，前端代码假设所有资产调度表达式都是以"all"为键的结构，但实际上调度表达式可能有三种形式：

1. 列表形式（正确解析）：{"all": [...]}
2. 直接引用形式（解析失败）：{"asset": ...}
3. 逻辑或形式（解析失败）：{"any": ...}

当开发者使用直接引用形式（非列表）时，前端尝试访问不存在的"all"键下的第一个元素，导致JavaScript报错。

临时解决方案

在等待官方修复的同时，开发者可以采用以下临时解决方案：

1. 使用列表形式定义调度依赖：

@asset(schedule=[test_asset])  # 使用列表形式
def test_asset_2():
    pass

2. 对于使用@dag装饰器的情况，同样适用列表形式：

@dag(schedule=[Asset("my_asset")])  # 正确形式
def my_dag():
    pass

影响范围

该问题不仅影响@asset装饰器，还会影响以下场景：

• 使用@dag装饰器直接引用Asset对象
• 使用@dag装饰器直接引用Dataset对象
• 在Airflow 2.10.5中可以正常工作的直接引用形式在3.0.0中会失效

开发者建议

对于数据管道开发者，建议：

1. 在定义资产或DAG的调度依赖时，始终使用列表形式
2. 升级到Airflow 3.0.0时，检查现有代码中是否存在直接引用形式的调度依赖
3. 关注官方修复进展，及时更新到包含修复的版本

该问题的修复将提升Airflow Web UI的稳定性，确保开发者能够正常查看和管理依赖关系复杂的DAG和资产。