`airflow.timetables.interval`¶

Module Contents¶

airflow.timetables.interval.Delta[source]¶

class airflow.timetables.interval.CronDataIntervalTimetable(cron: str, timezone: Timezone)[source]¶

Bases: airflow.timetables.interval._DataIntervalTimetable

Timetable that schedules data intervals with a cron expression.

This corresponds to schedule_interval=<cron>, where <cron> is either a five/six-segment representation, or one of cron_presets.

The implementation extends on croniter to add timezone awareness. This is because croniter works only with naive timestamps, and cannot consider DST when determining the next/previous time.

Don't pass @once in here; use OnceTimetable instead.

summary[source]¶

classmethod deserialize(cls, data: Dict[str, Any])[source]¶

__eq__(self, other: Any)[source]¶

Both expression and timezone should match.

This is only for testing purposes and should not be relied on otherwise.

serialize(self)[source]¶

validate(self)[source]¶

infer_manual_data_interval(self, *, run_after: DateTime)[source]¶

class airflow.timetables.interval.DeltaDataIntervalTimetable(delta: Delta)[source]¶

Bases: airflow.timetables.interval._DataIntervalTimetable

Timetable that schedules data intervals with a time delta.

This corresponds to schedule_interval=<delta>, where <delta> is either a datetime.timedelta or dateutil.relativedelta.relativedelta instance.

summary[source]¶

classmethod deserialize(cls, data: Dict[str, Any])[source]¶

__eq__(self, other: Any)[source]¶

The offset should match.

This is only for testing purposes and should not be relied on otherwise.

serialize(self)[source]¶

validate(self)[source]¶

infer_manual_data_interval(self, run_after: DateTime)[source]¶

airflow.timetables.interval¶

Module Contents¶

`airflow.timetables.interval`¶