airflow.timetables.simple

模块内容

类

NullTimetable

从不调度任何内容的时间表。

OnceTimetable

尽快调度一次执行的时间表。

ContinuousTimetable

持续调度的时间表，同时仍然遵守 start_date 和 end_date。
class airflow.timetables.simple.NullTimetable[source]

基类: _TrivialTimetable

从不调度任何内容的时间表。

这对应于 schedule=None。

property summary: str[source]

时间表的简短摘要。

这用于在 Web UI 中显示时间表。例如，cron 表达式时间表可以使用它来显示表达式。默认实现返回时间表的类型名称。

can_be_scheduled = False[source]
description: str = '从不，仅限外部触发器'[source]
next_dagrun_info(*, last_automated_data_interval, restriction)[source]

提供调度下一个 DagRun 的信息。

默认实现引发 NotImplementedError。

参数
返回

关于何时可以调度下一个 DagRun 的信息。None 表示不会发生 DagRun。这并不意味着此 DAG 不会再次安排更多运行；当在其他时间请求时，时间表可以返回 DagRunInfo 对象。

返回类型

airflow.timetables.base.DagRunInfo | None

class airflow.timetables.simple.OnceTimetable[source]

基类: _TrivialTimetable

尽快调度一次执行的时间表。

这对应于 schedule="@once"。

property summary: str[source]

时间表的简短摘要。

这用于在 Web UI 中显示时间表。例如，cron 表达式时间表可以使用它来显示表达式。默认实现返回时间表的类型名称。

description: str = '尽快运行一次'[source]
next_dagrun_info(*, last_automated_data_interval, restriction)[source]

提供调度下一个 DagRun 的信息。

默认实现引发 NotImplementedError。

参数
返回

关于何时可以调度下一个 DagRun 的信息。None 表示不会发生 DagRun。这并不意味着此 DAG 不会再次安排更多运行；当在其他时间请求时，时间表可以返回 DagRunInfo 对象。

返回类型

airflow.timetables.base.DagRunInfo | None

class airflow.timetables.simple.ContinuousTimetable[source]

基类: _TrivialTimetable

持续调度的时间表，同时仍然遵守 start_date 和 end_date。

这对应于 schedule="@continuous"。

property summary: str[source]

时间表的简短摘要。

这用于在 Web UI 中显示时间表。例如，cron 表达式时间表可以使用它来显示表达式。默认实现返回时间表的类型名称。

description: str = '尽可能频繁，但一次只能运行一个'[source]
active_runs_limit = 1[source]
next_dagrun_info(*, last_automated_data_interval, restriction)[source]

提供调度下一个 DagRun 的信息。

默认实现引发 NotImplementedError。

参数
返回

关于何时可以调度下一个 DagRun 的信息。None 表示不会发生 DagRun。这并不意味着此 DAG 不会再次安排更多运行；当在其他时间请求时，时间表可以返回 DagRunInfo 对象。

返回类型

airflow.timetables.base.DagRunInfo | None

此条目是否有帮助？