This is an automated email from the ASF dual-hosted git repository.
Lee-W pushed a commit to branch v3-3-test
in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/v3-3-test by this push:
new 70329c6d597 [v3-3-test] real example of CronDataIntervalTimetable and
DeltaDataIntervalTimetable (#70303) (#70434)
70329c6d597 is described below
commit 70329c6d5976cc3e3e56c84690661fd5e82f8b4f
Author: raphaelauv <[email protected]>
AuthorDate: Sun Jul 26 04:48:47 2026 +0200
[v3-3-test] real example of CronDataIntervalTimetable and
DeltaDataIntervalTimetable (#70303) (#70434)
---
.../docs/authoring-and-scheduling/timetable.rst | 20 +++++++++++++-------
1 file changed, 13 insertions(+), 7 deletions(-)
diff --git a/airflow-core/docs/authoring-and-scheduling/timetable.rst
b/airflow-core/docs/authoring-and-scheduling/timetable.rst
index b19cc802113..8724330057e 100644
--- a/airflow-core/docs/authoring-and-scheduling/timetable.rst
+++ b/airflow-core/docs/authoring-and-scheduling/timetable.rst
@@ -197,7 +197,7 @@ DeltaDataIntervalTimetable
^^^^^^^^^^^^^^^^^^^^^^^^^^
A timetable that schedules data intervals with a time delta. You can select it
by providing a
-:class:`datetime.timedelta` or ``dateutil.relativedelta.relativedelta`` to the
``schedule`` parameter of a Dag.
+:class:`DeltaDataIntervalTimetable` to the ``schedule`` parameter of a Dag.
This timetable focuses on the data interval value and does not necessarily
align execution dates with
arbitrary bounds, such as the start of day or of hour.
@@ -206,7 +206,12 @@ arbitrary bounds, such as the start of day or of hour.
.. code-block:: python
- @dag(schedule=datetime.timedelta(minutes=30))
+ from datetime import timedelta
+
+ from airflow.sdk import dag, DeltaDataIntervalTimetable
+
+
+ @dag(schedule=DeltaDataIntervalTimetable(timedelta(minutes=30)))
def example_dag():
pass
@@ -216,17 +221,18 @@ CronDataIntervalTimetable
^^^^^^^^^^^^^^^^^^^^^^^^^
A timetable that accepts a cron expression, creates data intervals according
to the interval between each cron
-trigger points, and triggers a Dag run at the end of each data interval.
+trigger points, and triggers a Dag run at the end of each data interval. You
can select it by providing a
+:class:`CronDataIntervalTimetable` to the ``schedule`` parameter of a Dag.
.. seealso:: `Differences between "trigger" and "data interval" timetables`_
.. seealso:: `Differences between the cron and delta data interval timetables`_
-Select this timetable by providing a valid cron expression as a string to the
``schedule``
-parameter of a Dag, as described in the :doc:`../core-concepts/dags`
documentation.
-
.. code-block:: python
- @dag(schedule="0 1 * * 3") # At 01:00 on Wednesday.
+ from airflow.sdk import dag, CronDataIntervalTimetable
+
+
+ @dag(schedule=CronDataIntervalTimetable("0 1 * * 3")) # At 01:00 on
Wednesday.
def example_dag():
pass
