ferruzzi commented on code in PR #70148:
URL: https://github.com/apache/airflow/pull/70148#discussion_r3661506444
##########
airflow-core/src/airflow/models/serialized_dag.py:
##########
@@ -645,6 +646,12 @@ def write_dag(
name_updated = False
reused_deadline_data: dict[str, dict] | None = None
if dag.data.get("dag", {}).get("deadline"):
+ # The deadline handling below rewrites data["dag"]["deadline"]
from a list of
+ # encoded dicts into a list of UUID references. Work on a copy so
we never mutate
+ # the caller's LazyDeserializedDAG in place.
+ from airflow.serialization.serialized_objects import
LazyDeserializedDAG
Review Comment:
~~I don't think this needs to be a local import; move it to the top if you
can.~~
Edit: Actually, see below.
--
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]
