我需要重新启动 Airflow。我想确保在空闲时执行此操作,这样我就不会通过重新启动 Airflow 的工作组件来中断工作。
如何查看正在运行的 DAG?
我在 UI 中看不到任何会列出当前正在运行的 DAG 的内容。
我在airflow
CLI 中没有看到任何命令来列出当前正在运行的 DAG。
我发现airflow shell
这可以让我连接到数据库,但我对 Airflow 内部结构的了解不够,不知道去哪里查看正在运行的内容。
您还可以查询数据库以一次获取所有正在运行的任务:
select * from task_instance where state='running'
本文收集自互联网,转载请注明来源。
如有侵权,请联系 [email protected] 删除。
我来说两句