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

0
votes

I am trying to build a custom UI built around the executions of airflow tasks. One piece of information I need is the cron schedule of each DAG.

I cannot find this in any of the tables used by the Airflow scheduler. Am I missing something obvious?

Without writing a crawler to parse DAG python files themselves, where can I find the cron schedules for my DAGs (by database connection, api call, or anything else that I can programmatically access)?

1
airflowairflow-scheduler

1 Answers

2
votes

Instantiate a airflow.models.DagBag object, all the DAG objects, and their schedule_interval (which has their scheduling information), is available from the dags dictionary attribute on the DagBag object. 

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