【发布时间】:2021-03-24 20:01:45
【问题描述】:
我正在尝试在 Apache Airflow 上创建一个简单的 DAG 工作流,其中数据更新到我的本地 PostgreSQL 数据库。
谁能告诉我为什么我的 DAG 失败了,我只有在使用 CeleryExecutor 时才会在日志中看到这些错误?我尝试使用 LocalExecutor 运行相同的 DAG,但没有出现任何错误,并且运行顺利。
这是日志错误:
*** Log file isn't local.
*** Fetching here: http://<worker hostname>:8793/log/PDI_Incr_20190407_v2/checkBCWatermarkDt/2019-04-07T17:00:00/1.log
*** Failed to fetch log file from worker. 404 Client Error: NOT FOUND for url: http://<worker hostname>:8793/log/PDI_Incr_20190407_v2/checkBCWatermarkDt/2019-04-07T17:00:00/1.log
感谢您的帮助!
【问题讨论】: