airflow.example_dags.plugins.workday¶
Plugin to demonstrate timetable registration and accommodate example DAGs.
Module Contents¶
Classes¶
Protocol that all Timetable classes are expected to implement. |
|
Class used to define AirflowPlugin. |
- class airflow.example_dags.plugins.workday.AfterWorkdayTimetable[source]¶
Bases:
airflow.timetables.base.TimetableProtocol that all Timetable classes are expected to implement.
- infer_manual_data_interval(self, run_after)[source]¶
When a DAG run is manually triggered, infer a data interval for it.
This is used for e.g. manually-triggered runs, where
run_afterwould be when the user triggers the run. The default implementation raisesNotImplementedError.
- next_dagrun_info(self, *, 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]