如何以编程方式访问我的 Airflow DAG 的 cron 计划？

Question

我正在尝试构建一个围绕气流任务执行的自定义 UI。我需要的一条信息是每个 DAG 的 cron 计划。

我在 Airflow 调度程序使用的任何表中都找不到它。我是否漏掉了一些明显的东西？

无需编写爬虫程序来解析 DAG python 文件本身，我在哪里可以找到我的 DAG 的 cron 计划（通过数据库连接、api 调用或我可以通过编程访问的任何其他方式)?

Answer 1

实例化一个 airflow.models.DagBag 对象，所有 DAG 对象，以及它们的 schedule_interval（具有它们的调度信息），可从 dags 字典属性中获得DagBag 对象。

from airflow import models
dag_bag = models.DagBag()
for dag in dag_bag.dags.values():
    print(dag.schedule_interval)

How can I programmatically access the cron schedules for my Airflow DAGs?