如何获取DAG状态,如正在运行、成功或失败 [英] How to get dag status like running or success or failure
本文介绍了如何获取DAG状态,如正在运行、成功或失败的处理方法,对大家解决问题具有一定的参考价值,需要的朋友们下面随着小编来一起学习吧!
问题描述
我想知道DAG的状态是正在运行、失败还是成功。我正在通过CL参数气流触发器触发DAG,在作业执行之后,我想知道运行的状态。我找不到任何办法。
我尝试了气流dag_state,但没有给出任何提示。如果一天中有多次运行以通过命令行参数或python代码获取最近一次运行的状态,我应该怎么办。
CLI
您可以将list_dag_runs命令与推荐答案配合使用,以列出给定DAG ID的DAG运行。返回的信息包括每次运行的状态。
您还可以通过python代码以几种不同的方式检索信息。我过去使用的一种方法是'find' method in airflow.models.dagrun.DagRun
如何通过DagRun.find()获取dag_run的状态的python3示例:
dag_id = 'fake_dag_id'
dag_runs = DagRun.find(dag_id=dag_id)
for dag_run in dag_runs:
print(dag_run.state)
这篇关于如何获取DAG状态,如正在运行、成功或失败的文章就介绍到这了,希望我们推荐的答案对大家有所帮助,也希望大家多多支持IT屋!
查看全文