uranusjr commented on code in PR #62463:
URL: https://github.com/apache/airflow/pull/62463#discussion_r2867160216
##########
airflow-core/src/airflow/timetables/trigger.py:
##########
@@ -522,10 +524,9 @@ def generate_run_id(
suffix = f"{suffix}__{get_random_string()}"
return run_type.generate_run_id(suffix=suffix)
- def next_run_info_from_dag_model(self, *, dag_model: DagModel) ->
DagRunInfo:
- run_after =
timezone.coerce_datetime(dag_model.next_dagrun_create_after)
- if TYPE_CHECKING:
- assert run_after is not None
+ def next_run_info_from_dag_model(self, *, dag_model: DagModel) ->
DagRunInfo | None:
Review Comment:
Good point, let me raise this logic to the base Timetable class.
--
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]
