airflow.timetables.simple¶
Module Contents¶
Classes¶
| Timetable that never schedules anything. | |
| Timetable that schedules the execution once as soon as possible. | 
- class airflow.timetables.simple.NullTimetable[source]¶
- Bases: - _TrivialTimetable- Timetable that never schedules anything. - This corresponds to - schedule_interval=None.- property summary[source]¶
- A short summary for the timetable. - This is used to display the timetable in the web UI. A cron expression timetable, for example, can use this to display the expression. The default implementation returns the timetable’s type name. 
 - next_dagrun_info(*, last_automated_data_interval, restriction)[source]¶
- Provide information to schedule the next DagRun. - The default implementation raises - NotImplementedError.- Parameters
- last_automated_data_interval (Optional[airflow.timetables.base.DataInterval]) – The data interval of the associated DAG’s last scheduled or backfilled run (manual runs not considered). 
- restriction (airflow.timetables.base.TimeRestriction) – Restriction to apply when scheduling the DAG run. See documentation of - TimeRestrictionfor details.
 
- Returns
- Information on when the next DagRun can be scheduled. None means a DagRun will not happen. This does not mean no more runs will be scheduled even again for this DAG; the timetable can return a DagRunInfo object when asked at another time. 
- Return type
- Optional[airflow.timetables.base.DagRunInfo] 
 
 
- class airflow.timetables.simple.OnceTimetable[source]¶
- Bases: - _TrivialTimetable- Timetable that schedules the execution once as soon as possible. - This corresponds to - schedule_interval="@once".- property summary[source]¶
- A short summary for the timetable. - This is used to display the timetable in the web UI. A cron expression timetable, for example, can use this to display the expression. The default implementation returns the timetable’s type name. 
 - next_dagrun_info(*, last_automated_data_interval, restriction)[source]¶
- Provide information to schedule the next DagRun. - The default implementation raises - NotImplementedError.- Parameters
- last_automated_data_interval (Optional[airflow.timetables.base.DataInterval]) – The data interval of the associated DAG’s last scheduled or backfilled run (manual runs not considered). 
- restriction (airflow.timetables.base.TimeRestriction) – Restriction to apply when scheduling the DAG run. See documentation of - TimeRestrictionfor details.
 
- Returns
- Information on when the next DagRun can be scheduled. None means a DagRun will not happen. This does not mean no more runs will be scheduled even again for this DAG; the timetable can return a DagRunInfo object when asked at another time. 
- Return type
- Optional[airflow.timetables.base.DagRunInfo] 
 
 
