如何获取DAG状态，如正在运行、成功或失败 [英] How to get dag status like running or success or failure

问题描述

我想知道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屋！