Airflow TaskGroup状态显示失败但内部任务均成功，求助排查原因

问题描述 #

我的DAG包含两个TaskGroup，每个TaskGroup内有若干PythonOperator。运行DAG后，所有PythonOperator均执行成功，DAG也被标记为成功，但在UI的网格视图中，这两个TaskGroup的状态显示为失败。

可能的原因及解决方法 #

• Airflow版本兼容性bug：Airflow 2.0.x至2.1.x版本中存在TaskGroup状态计算的已知bug，会导致内部任务全成功但TaskGroup显示失败。解决方法：运行airflow version查看版本，若低于2.2，升级到最新稳定版。
• TaskGroup依赖配置错误：若TaskGroup被错误关联了未执行/失败的外部任务，或TaskGroup之间的依赖逻辑与内部任务依赖不匹配，会导致状态异常。解决方法：核对TaskGroup的set_upstream/set_downstream或>>/<<依赖配置，确保依赖关系符合业务逻辑。
• 自定义TaskGroup类逻辑错误：如果使用了继承TaskGroup的自定义类，重写的状态计算相关方法（如get_state）可能存在逻辑错误。解决方法：暂时改用原生TaskGroup测试，若恢复正常则排查自定义类的代码问题。
• 元数据库脏数据：Airflow元数据库中关于TaskGroup的状态记录出现异常。解决方法：通过Airflow UI删除对应TaskGroup的任务实例记录后重新运行DAG；或使用airflow db clean清理旧元数据（操作前请备份数据库）。

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