airflow.timetables.simple¶

类¶

`NullTimetable`	从不调度任何东西的时间表。
`OnceTimetable`	尽快调度执行一次的时间表。
`ContinuousTimetable`	持续调度的时间表，同时仍遵守 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 对象。

返回类型：

airflow.timetables.base.DagRunInfo | None

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 对象。

返回类型：

airflow.timetables.base.DagRunInfo | None

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 对象。

返回类型：

airflow.timetables.base.DagRunInfo | None