`airflow.example_dags.plugins.workday`¶

用於示範時間表註冊並容納範例 DAG 的外掛程式。

模組內容¶

`AfterWorkdayTimetable`	所有時間表類別都應實作的協定。
`WorkdayTimetablePlugin`	用於定義 AirflowPlugin 的類別。

`log`
`holiday_calendar`

class airflow.example_dags.plugins.workday.AfterWorkdayTimetable[source]¶

所有時間表類別都應實作的協定。

get_next_workday(d, incr=1)[source]¶

infer_manual_data_interval(run_after)[source]¶

當 DAG 執行被手動觸發時，推斷其資料間隔。

這用於例如手動觸發的執行，其中 run_after 將會是使用者觸發執行時的時間。預設實作會引發 NotImplementedError。

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.example_dags.plugins.workday.WorkdayTimetablePlugin[source]¶

繼承自： airflow.plugins_manager.AirflowPlugin

用於定義 AirflowPlugin 的類別。