无需Web服务器即可重新启动apag气流

Question

有什么方法可以重新加载作业，而不必重新启动服务器？

Answer 1

在中airflow.cfg，您具有以下两种配置来控制此行为：

# after how much time a new DAGs should be picked up from the filesystem
min_file_process_interval = 0
dag_dir_list_interval = 60

您可能必须重新加载Web服务器，调度程序和工作程序才能使新配置生效。

Answer 2

更新关联的python文件时，应该重新加载Dags。

如果不是，请首先尝试通过单击看起来像回收符号的按钮在UI中手动刷新它们：

如果这样不起作用，请删除dags文件夹中的所有.pyc文件。

通常，尽管如此，当我保存python文件时，dag会在几分钟后更新。

Answer 3

我有相同的问题，但尚未看到此答案。我能够从命令行执行以下操作：

python -c "from airflow.models import DagBag; d = DagBag();"

当Web服务器运行时，默认情况下，它每30秒左右刷新一次刷新，但是如果需要，它将在两次刷新之间刷新刷新。