如何检查 Airflow 中是否有 DAG 正在运行(在重新启动 Airflow 之前)?

阿列克谢·察洛利欣

我需要重新启动 Airflow。我想确保在空闲时执行此操作,这样我就不会通过重新启动 Airflow 的工作组件来中断工作。

如何查看正在运行的 DAG?

我在 UI 中看不到任何会列出当前正在运行的 DAG 的内容。

我在airflowCLI 中没有看到任何命令来列出当前正在运行的 DAG。

我发现airflow shell这可以让我连接到数据库,但我对 Airflow 内部结构的了解不够,不知道去哪里查看正在运行的内容。

菲利普·约翰尼斯

您还可以查询数据库以一次获取所有正在运行的任务:

select * from task_instance where state='running'

本文收集自互联网,转载请注明来源。

如有侵权,请联系 [email protected] 删除。

编辑于
0

我来说两句

0 条评论
登录 后参与评论

相关文章