python - 如何检查我的下一次 Airflow DAG 运行何时安排在特定的 dag 上？

Question

我设置了 Airflow 并运行一些 DAG，计划每天一次“0 0 * * *”。

我想检查下一次安排运行特定 dag 的时间，但我看不到我可以在管理员中的什么地方执行此操作。

Answer 1

如果你想使用Airflow的CLI，有next_execution option

Get the next execution datetime of a DAG.

airflow next_execution [-h] [-sd SUBDIR] dag_id

---

UPDATE-1

如果您需要以编程方式进行(在 Airflow task 中)，您可以引用

• next_execution(..) function的 cli.py
• (现在移至 dag_next_execution(..) function 中的 dag_command.py 的 master )

@cli_utils.action_logging
def next_execution(args):
    """
    Returns the next execution datetime of a DAG at the command line.
    >>> airflow next_execution tutorial
    2018-08-31 10:38:00
    """
    dag = get_dag(args)

    if dag.is_paused:
        print("[INFO] Please be reminded this DAG is PAUSED now.")

    if dag.latest_execution_date:
        next_execution_dttm = dag.following_schedule(dag.latest_execution_date)

        if next_execution_dttm is None:
            print("[WARN] No following schedule can be found. " +
                  "This DAG may have schedule interval '@once' or `None`.")

        print(next_execution_dttm)
    else:
        print("[WARN] Only applicable when there is execution record found for the DAG.")
        print(None)

---

UPDATE-2

不仅要获得下一个，还要获得更多的 execution_date，请参阅 Airflow - how to get all the future run date