Tegh25 commented on code in PR #68359:
URL: https://github.com/apache/airflow/pull/68359#discussion_r3431777671
##########
airflow-core/docs/administration-and-deployment/logging-monitoring/callbacks.rst:
##########
@@ -95,6 +98,46 @@ For example, a timeout may be caused by a number of stalling
tasks, but only one
Before Airflow 3.2.0, the rules above did not apply and the task instance
passed to Dag callback was not related to Dag state, rather being selected as
the latest task in the Dag
lexicographically.
+Skipped Intervals Callback
+^^^^^^^^^^^^^^^^^^^^^^^^^^
+
+When a Dag is defined with ``catchup=False``, the scheduler may advance past
missed scheduled
+intervals without creating Dag runs for them. Set
``on_skipped_intervals_callback`` on the Dag
+to be notified when that happens.
+
Review Comment:
The callback will not trigger on every scheduler pass as long as a the Dag
remains paused. The callback will instead return all the skipped intervals once
the scheduler creates the next scheduled Dag run after the Dag is resumed. I
believe throttling is not needed here.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
