`airflow.example_dags.plugins.workday`¶

插件，用于演示时间表注册并适应示例 DAG。

模块内容¶

`AfterWorkdayTimetable`	所有时间表类都应实现的协议。
`WorkdayTimetablePlugin`	用于定义 AirflowPlugin 的类。

`log`
`holiday_calendar`

class airflow.example_dags.plugins.workday.AfterWorkdayTimetable[源代码]¶

所有时间表类都应实现的协议。

get_next_workday(d, incr=1)[源代码]¶

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

class airflow.example_dags.plugins.workday.WorkdayTimetablePlugin[源代码]¶

基类： airflow.plugins_manager.AirflowPlugin

用于定义 AirflowPlugin 的类。