更新添加任务后未找到气流 DAG 任务

Question

我在更新 dag 文件时遇到问题。Dag 仍然有我的 dag 文件的旧版本。我添加了一个任务，但当我检查日志和 UI（DAG->代码）时它似乎没有更新。

我有非常简单的任务。我当然检查了 dag 目录路径airflow.cfg并重新启动airflow webserver/scheduler。我运行它没有问题（但使用旧的 dag 文件）。

Answer 1

看起来像是气流的错误。临时解决方案是通过以下方式从气流数据库中删除任务实例

delete from task_instance where dag_id=<dag_name> and task_id=<deleted_task_name>';

这应该比 ResetDB 路由更简单，影响更小，因为 ResetDB 路由会删除之前设置的所有内容，包括变量和连接。

Answer 2

您可以尝试删除 dags 文件夹中该 dag 的旧 .pyc 文件，然后重新生成它。