气流 dag 文件已到位,但当我执行气流 dags 列表时它没有显示



我根据教程在dags文件夹中放置了一个dag文件,并进行了轻微修改,但它没有显示在GUI中,也没有显示在运行气流dags列表时。

回答我自己的问题:通过直接运行它来检查python文件中的异常。结果是,由于缺少导入,dag的python脚本中出现了一个异常,导致dag没有显示在列表中。我注意到这一点,以防其他新用户遇到这个问题。对我来说,这个故事的寓意是,当dag文件被修改时,应该经常通过直接运行python来检查,因为否则不会出现明显的错误;他们可能会从列表中消失。

我知道你已经自己回答了,但是我不能评论,我想分享一个类似的案例。

一个python文件可以是有效的可执行python,在正确的位置,具有正确的权限,并被气流检测…但它仍然不会显示,除非一个有效的DAG对象已经实例化(如果没有,则不会记录错误)。

您还必须实例化对象,而不仅仅是调用函数-在我的情况下,当我像这样更改它时,DAG最终开始出现…

from airflow.decorators import dag
@dag(...)
def the_dag()
...
the_dag() # <-- doesn't work
_ = the_dag() # <-- works

最新更新