`airflow.timetables.datasets`¶

模块内容¶

将基于时间的调度与基于事件的调度相结合。

class airflow.timetables.datasets.DatasetOrTimeSchedule(*, timetable, datasets)[源代码]¶

基类： airflow.timetables.simple.DatasetTriggeredTimetable

将基于时间的调度与基于事件的调度相结合。

property summary: str[源代码]¶

时间表的简短摘要。

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

classmethod deserialize(data)[源代码]¶

从数据反序列化时间表。

当反序列化序列化的 DAG 时调用此方法。 data 将是 DAG 序列化期间 serialize 返回的任何内容。默认实现构造不带任何参数的时间表。

序列化时间表以进行 JSON 编码。

在 DAG 序列化期间调用此方法，以将时间表信息存储在数据库中。此方法应返回一个 JSON 可序列化的字典，该字典将在反序列化 DAG 时馈送到 deserialize 中。默认实现返回一个空字典。

验证时间表是否正确指定。

覆盖此方法以在将 DAG 放入 dagbag 时提供运行时验证。默认实现不执行任何操作。

infer_manual_data_interval(*, run_after)[源代码]¶

手动触发 DAG 运行时，为其推断数据间隔。

这用于例如手动触发的运行，其中 run_after 将是用户触发运行的时间。默认实现引发 NotImplementedError。

next_dagrun_info(*, last_automated_data_interval, restriction)[源代码]¶

提供信息以调度下一个 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

generate_run_id(*, run_type, **kwargs)[源代码]¶