CODEWITHSUNDEEP
airflowairflow-scheduler
Stephen Bourget
Stephen Bourget

Reputation: 3

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

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)?

Upvotes: 0

Views: 1049

Answers (1)

joebeeson
joebeeson

Reputation: 4366

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)

Upvotes: 5

Related Questions