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]

Was this entry helpful?