airflow.timetables.simple¶
类¶
从不调度任何东西的时间表。 |
|
尽快调度执行一次的时间表。 |
|
持续调度的时间表,同时仍遵守 start_date 和 end_date。 |
模块内容¶
- class airflow.timetables.simple.NullTimetable[source]¶
基类:
_TrivialTimetable
从不调度任何东西的时间表。
这对应于
schedule=None
。- can_be_scheduled = False[source]¶
此时间表是否能以自动化方式实际调度运行。
此值默认为 *True*,并且通常应该为 *True*(包括 *@once* 等非周期性执行类型和数据触发的时间表),但
NullTimetable
将此值设置为 *False*。
- description: str = '永不,仅限外部触发'[source]¶
时间表的人类可读描述。
例如,它可以从 cron 表达式
'30 21 * * 5'
生成类似'周五 21:30'
的描述。这在 webserver UI 中使用。
- property summary: str[source]¶
时间表的简短摘要。
这用于在 web UI 中显示时间表。例如,cron 表达式时间表可以使用此属性显示表达式。默认实现返回时间表的类型名称。
- next_dagrun_info(*, last_automated_data_interval, restriction)[source]¶
提供调度下一个 DagRun 的信息。
默认实现会引发
NotImplementedError
。- 参数:
last_automated_data_interval (airflow.timetables.base.DataInterval | None) – 相关联 DAG 最后一次调度或回填运行(不考虑手动运行)的数据间隔。
restriction (airflow.timetables.base.TimeRestriction) – 调度 DAG 运行时应用的限制。详细信息请参阅
TimeRestriction
的文档。
- 返回:
关于何时可以调度下一个 DagRun 的信息。None 表示不会发生 DagRun。这并不意味着此 DAG 不会再被调度;在其他时间询问时,时间表可能返回 DagRunInfo 对象。
- 返回类型:
- class airflow.timetables.simple.OnceTimetable[source]¶
基类:
_TrivialTimetable
尽快调度执行一次的时间表。
这对应于
schedule="@once"
。- description: str = '一次,尽快'[source]¶
时间表的人类可读描述。
例如,它可以从 cron 表达式
'30 21 * * 5'
生成类似'周五 21:30'
的描述。这在 webserver UI 中使用。
- property summary: str[source]¶
时间表的简短摘要。
这用于在 web UI 中显示时间表。例如,cron 表达式时间表可以使用此属性显示表达式。默认实现返回时间表的类型名称。
- next_dagrun_info(*, last_automated_data_interval, restriction)[source]¶
提供调度下一个 DagRun 的信息。
默认实现会引发
NotImplementedError
。- 参数:
last_automated_data_interval (airflow.timetables.base.DataInterval | None) – 相关联 DAG 最后一次调度或回填运行(不考虑手动运行)的数据间隔。
restriction (airflow.timetables.base.TimeRestriction) – 调度 DAG 运行时应用的限制。详细信息请参阅
TimeRestriction
的文档。
- 返回:
关于何时可以调度下一个 DagRun 的信息。None 表示不会发生 DagRun。这并不意味着此 DAG 不会再被调度;在其他时间询问时,时间表可能返回 DagRunInfo 对象。
- 返回类型:
- class airflow.timetables.simple.ContinuousTimetable[source]¶
基类:
_TrivialTimetable
持续调度的时间表,同时仍遵守 start_date 和 end_date。
这对应于
schedule="@continuous"
。- description: str = '尽可能频繁,但一次只允许一个运行。'[source]¶
时间表的人类可读描述。
例如,它可以从 cron 表达式
'30 21 * * 5'
生成类似'周五 21:30'
的描述。这在 webserver UI 中使用。
- active_runs_limit = 1[source]¶
一个 DAG 同时可以处于活动状态的最大运行数。
这在 DAG 初始化期间调用,返回值用作 DAG 的默认
max_active_runs
。此值通常应返回 *None*,但在某些情况下限制 DAG 运行并行性有充分理由,例如对于ContinuousTimetable
。
- property summary: str[source]¶
时间表的简短摘要。
这用于在 web UI 中显示时间表。例如,cron 表达式时间表可以使用此属性显示表达式。默认实现返回时间表的类型名称。
- next_dagrun_info(*, last_automated_data_interval, restriction)[source]¶
提供调度下一个 DagRun 的信息。
默认实现会引发
NotImplementedError
。- 参数:
last_automated_data_interval (airflow.timetables.base.DataInterval | None) – 相关联 DAG 最后一次调度或回填运行(不考虑手动运行)的数据间隔。
restriction (airflow.timetables.base.TimeRestriction) – 调度 DAG 运行时应用的限制。详细信息请参阅
TimeRestriction
的文档。
- 返回:
关于何时可以调度下一个 DagRun 的信息。None 表示不会发生 DagRun。这并不意味着此 DAG 不会再被调度;在其他时间询问时,时间表可能返回 DagRunInfo 对象。
- 返回类型: