Apache Airflow 自定义时间表
概述 Airflow 可以自定义任务的执行时间，为了那些在时间表中难以自定义的时间，例如农历放假时间等 class AfterWorkdayTimetable(Timetable): def __init__(self, schedule_at: Time): self._schedule_at = schedule_at @lru_cache(maxsize=512) def _is_holiday(self, d) -> bool: return fetch_date_info(d).get("is_holiday", False) def get_next_workday(self, d, incr=1): next_start = d while self._is_holiday(next_start.date()):...
