airflow.timetables.simple
¶
模組內容¶
類別¶
永不排程任何內容的時間表。 |
|
儘快排程執行一次的時間表。 |
|
持續排程,同時仍遵守 start_date 和 end_date 的時間表。 |
- class airflow.timetables.simple.NullTimetable[source]¶
基底:
_TrivialTimetable
永不排程任何內容的時間表。
這對應於
schedule=None
。- property summary: str[source]¶
時間表的簡短摘要。
這用於在網頁 UI 中顯示時間表。例如,cron 表達式時間表可以使用它來顯示表達式。預設實作會傳回時間表的類型名稱。
- 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 物件。
- 傳回類型
- class airflow.timetables.simple.OnceTimetable[source]¶
基底:
_TrivialTimetable
儘快排程執行一次的時間表。
這對應於
schedule="@once"
。- property summary: str[source]¶
時間表的簡短摘要。
這用於在網頁 UI 中顯示時間表。例如,cron 表達式時間表可以使用它來顯示表達式。預設實作會傳回時間表的類型名稱。
- 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 物件。
- 傳回類型
- class airflow.timetables.simple.ContinuousTimetable[source]¶
基底:
_TrivialTimetable
持續排程,同時仍遵守 start_date 和 end_date 的時間表。
這對應於
schedule="@continuous"
。- property summary: str[source]¶
時間表的簡短摘要。
這用於在網頁 UI 中顯示時間表。例如,cron 表達式時間表可以使用它來顯示表達式。預設實作會傳回時間表的類型名稱。
- 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 物件。
- 傳回類型