airflow.example_dags.plugins.workday¶

用于演示时间表注册并容纳示例 DAG 的插件。

属性¶

`log`
`holiday_calendar`

`AfterWorkdayTimetable`	所有 Timetable 类应实现的协议。
`WorkdayTimetablePlugin`	用于定义 AirflowPlugin 的类。

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

所有 Timetable 类应实现的协议。

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 的类。