@daily задаёт ежедневное расписание около полуночи в часовой зоне DAG. Фактический запуск зависит от timetable, scheduler и доступных ресурсов.
Если расписание DAG — @daily, во сколько он фактически запускается?
@daily задаёт ежедневное расписание около полуночи в часовой зоне DAG. Фактический запуск зависит от timetable, scheduler и доступных ресурсов.
Короткий ответ
Что ответить на собеседовании
Подробный разбор
Ответ с пояснениями
@daily задаёт ежедневное расписание около полуночи в часовой зоне DAG. Фактический запуск зависит от timetable, scheduler и доступных ресурсов.
При расписании с интервалами данных запуск обычно создаётся после завершения суточного интервала: обработка данных за понедельник начинается не раньше границы со вторником. Logical date при этом обозначает начало интервала, а не время старта процесса.
Проверьте используемый timetable, start_date, часовой пояс, catchup и ограничения активных запусков. Даже когда запуск уже положен по расписанию, очередь и занятые worker-слоты могут задержать выполнение. Поэтому «всегда ровно в 00:00» — неточный ответ.
Источник: Документация Apache Kafka.