dstandish commented on code in PR #59115:
URL: https://github.com/apache/airflow/pull/59115#discussion_r2713387942
##########
airflow-core/src/airflow/timetables/base.py:
##########
@@ -315,3 +329,24 @@ def generate_run_id(
:param data_interval: The data interval of the DAG run.
"""
return run_type.generate_run_id(suffix=run_after.isoformat())
+
+ def next_dagrun_info_v2(self, *, last_dagrun_info: DagRunInfo | None,
restriction: TimeRestriction):
+ """
+ Provide information to schedule the next DagRun.
+
+ The default implementation raises ``NotImplementedError``.
+
+ :param last_dagrun_info: The DagRunInfo object of the
+ Dag's last scheduled or backfilled run.
+ :param restriction: Restriction to apply when scheduling the DAG run.
+ See documentation of :class:`TimeRestriction` for details.
+
+ :return: Information on when the next DagRun can be scheduled. None
+ means a DagRun should not be created. This does not mean no more
runs
+ will be scheduled ever again for this DAG; the timetable can return
Review Comment:
done
--
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]
