تشغيلات DAG وفترات البيانات واللحاق

from datetime import datetime, timedelta, timezone
start = datetime(2026, 10, 1, tzinfo=timezone.utc)
end = start + timedelta(days=1)
points = [start, end - timedelta(seconds=1), end]
inside = [point for point in points if start <= point < end]
assert len(inside) == 2
print(len(inside))

2

يستبعد حد النهاية؛ ولا ينفذ جدول Airflow.

from datetime import datetime, timezone
from airflow.sdk import dag, task
from airflow.timetables.interval import CronDataIntervalTimetable

@dag(schedule=CronDataIntervalTimetable('0 0 * * *', timezone='UTC'), start_date=datetime(2026, 10, 1, tzinfo=timezone.utc), catchup=False)
def lab_daily_report():
    @task
    def identify():
        return 'interval-bound-report'
    identify()

lab_daily_report()

الجدول تصريحي وغير منفذ؛ ولا تختار التسمية صفوف المصدر.