Airflow DAG не слушает @monthly schedule_interval

Question

Я пытаюсь запланировать ежемесячную DAG в Airflow. Он работает на ежедневной основе, хотя dag.schedule_interval = '@monthly' (согласно инструкциям здесь http://airflow.readthedocs.org/en/latest/scheduler.html#dag-runs). Я также установил dag_args['start_date'] = datetime(2016, 2, 1, 20, 0) и starts_at = time(13,0). Любые мысли, почему это может произойти?

Должен ли я использовать что-то вроде следующей установки?

dag_args['start_date'] = datetime(2016, 2, 1, 0, 0)

dag_args['schedule_interval'] = '0 19 1 * *'

Answer 1

Во-первых, ваша ссылка на "Dag Run" должно быть "https://pythonhosted.org/airflow/scheduler.html#dag-runs".

Во-вторых, вы можете проверить мой «привет» суть в https://gist.github.com/yuyou/baa73df674d1dbcbc14d35b1fc293415

Используйте «засыпку» команду, чтобы проверить ДАГ:

воздуха засыпки привет -s 2016-01-01 -e 2016-04 -01

И вы должны увидеть, что есть 4 прогона, как ожидалось.

Yu