【问题标题】:how to get airflow DAG execution date using command line?如何使用命令行获取气流 DAG 执行日期?
【发布时间】:2019-05-02 19:00:51
【问题描述】:

为了让我获得 dag_state,我运行以下 LCI 命令:

airflow dag_state  example_bash_operator '12-12T16:04:46.960661+00:00'

问题是 - 我必须明确地将确切的日期时间(即 execution_date)传递给这个命令。 当我运行 airflow list_dags 时,我只得到 DAG 的列表,但没有它们的执行日期。

有没有办法获取准确的日期时间(i.e. -> '12-12T16:04:46.960661+00:00')

对于给定的 dag,使用命令行 CLI?

【问题讨论】:

    标签: airflow


    【解决方案1】:

    这里有一个概念问题。 Dags 是有时间表的对象,而不是执行日期。当计划到期时,将为该Dag 创建DagRuns,并使用适当的execution_date

    因此,您可以使用 CLI 并提供 execution_date 来询问 DagRun 的状态,因为执行日期(几乎唯一)映射到特定的 DagRun。几乎独一无二,因为在实践中,您可以使用相同的 execution_date 触发两个 DagRuns,但这是一种不寻常的情况。

    但是,如果您询问Dagexecution_date,您真正想知道什么?最近创建的DagRunexecution_date?当前运行的DagRuns 的execution_dates 列表?

    您可以检查list_dag_runsdag_id CLI 命令,看看您是否可以根据您的需要对其进行过滤。

    【讨论】:

      猜你喜欢
      • 2017-09-06
      • 1970-01-01
      • 2021-07-18
      • 2019-01-26
      • 1970-01-01
      • 2021-01-03
      • 2018-05-28
      • 1970-01-01
      • 1970-01-01
      相关资源
      最近更新 更多