uranusjr commented on code in PR #58655:
URL: https://github.com/apache/airflow/pull/58655#discussion_r2567260313
##########
airflow-core/src/airflow/models/dag.py:
##########
@@ -598,20 +598,29 @@ def dags_needing_dagruns(cls, session: Session) ->
tuple[Any, dict[str, datetime
evaluator = AssetEvaluator(session)
- def dag_ready(dag_id: str, cond: BaseAsset, statuses:
dict[AssetUniqueKey, bool]) -> bool | None:
+ def dag_ready(dag_id: str, cond: BaseAsset, statuses:
dict[AssetUniqueKey, bool]) -> bool:
try:
return evaluator.run(cond, statuses)
except AttributeError:
# if dag was serialized before 2.9 and we *just* upgraded,
# we may be dealing with old version. In that case,
# just wait for the dag to be reserialized.
- log.warning("dag '%s' has old serialization; skipping DAG run
creation.", dag_id)
- return None
+ log.warning("Dag '%s' has old serialization; skipping run
creation.", dag_id)
+ return False
Review Comment:
Added
--
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]
