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

Ric*_*uly 3 directed-acyclic-graphs airflow

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

Ric*_*uly 6

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

  • 是的!我会检查 DagFileProcessor 日志以了解 Airflow 未成功解析文件的原因。日志将位于“$AIRFLOW_HOME/logs/scheduler/latest/<path_to_dag_file>.log”下。 (2认同)