airflow.timetables.interval¶
属性¶
类¶
使用 cron 表达式调度数据间隔的时间表。 |
|
使用时间差(time delta)调度数据间隔的时间表。 |
模块内容¶
- class airflow.timetables.interval.CronDataIntervalTimetable(cron, timezone)[source]¶
基类:
airflow.timetables._cron.CronMixin
,_DataIntervalTimetable
使用 cron 表达式调度数据间隔的时间表。
这对应于
schedule=<cron>
,其中<cron>
是一个五段式或六段式表示,或是cron_presets
中的一个。此实现扩展了 croniter 以增加时区感知能力。这是因为 croniter 仅适用于朴素时间戳,无法在确定下一或上一时间时考虑夏令时(DST)。
不要在此处传递
@once
;请改用OnceTimetable
。- classmethod deserialize(data)[source]¶
从数据反序列化时间表。
在反序列化序列化后的 DAG 时调用此方法。
data
将是 DAG 序列化期间由serialize
返回的任何内容。默认实现构造时间表时不带任何参数。
- class airflow.timetables.interval.DeltaDataIntervalTimetable(delta)[source]¶
基类:
airflow.timetables._delta.DeltaMixin
,_DataIntervalTimetable
使用时间差(time delta)调度数据间隔的时间表。
这对应于
schedule=<delta>
,其中<delta>
是datetime.timedelta
或dateutil.relativedelta.relativedelta
实例。- classmethod deserialize(data)[source]¶
从数据反序列化时间表。
在反序列化序列化后的 DAG 时调用此方法。
data
将是 DAG 序列化期间由serialize
返回的任何内容。默认实现构造时间表时不带任何参数。