调试损坏的DAG

arb*_*002 11 airflow apache-airflow

当气流网络服务器显示错误时Broken DAG: [<path/to/dag>] <error>,我们如何以及在何处找到这些异常的完整堆栈跟踪?

我试过这些地方:

/var/log/airflow/webserver- 在执行的时间范围内没有日志,其他日志是二进制的,并且解码时strings没有给出有用的信息.

/var/log/airflow/scheduler - 有一些日志,但是是二进制形式,试图阅读它们,看起来主要是sqlalchemy日志可能是气流的数据库.

/var/log/airflow/worker - 显示运行DAG的日志(与您在气流页面上看到的日志相同)

然后也在/var/log/airflow/rotated- 找不到我正在寻找的堆栈跟踪.

我使用的是airflow v1.7.1.3

Bab*_*ool 11

通常我使用airflow list_dags打印完整堆栈跟踪的命令来查找dags中发现的python错误.

每次使用气流CLI命令时,这几乎适用于任何气流命令,如气流分析dags文件夹.


Che*_*zhi 9

如果你想编译并查看任何语法错误,你也可以尝试 python your_dag.py