Я хочу добавить расписание (каждую пятницу в 8:00) в DAG. Ниже мой конфиг для DAG:
DAG CONFIG:
args = {
'owner': 'airflow',
'start_date': airflow.utils.dates.days_ago(20),
'depends_on_past': False,
'email': [failure_email],
'email_on_failure': True,
'email_on_retry': True,
}
dag = DAG(dag_id='dag_airflow_delete_logs_less_than_40_days',
default_args=args,
schedule_interval='0 8 * * 5',
max_active_runs=1)
После добавления расписания в DAG воздушный поток не уловил отметку в пятницу, 8:00 по UTC. Я удалил «5» из расписания crontab и настроил «0 8 * * *», он работал нормально каждый день.
Я также пробовал разные способы планирования интервалов с использованием формата crontab, но все же не повезло:
(0 8 * * 5)
(0 8 * * FRI)
Я не понимаю, почему это не работает, когда я задаю день в интервале? Пожалуйста, поделись своими мыслями. Заранее спасибо!
Примечание: я использовал указанные ниже сайты для проверки конфигов crontab.
1) https://crontab.guru/
2) http://corntab.com
Прикрепленный снимок экрана для прогонов DAG: http://tinypic.com/view.php?pic=5x4x3d&s=9#.W-RSjLpFyFQ