blinkseb commented on code in PR #30392:
URL: https://github.com/apache/airflow/pull/30392#discussion_r1157124016
##########
airflow/models/dagbag.py:
##########
@@ -201,18 +202,22 @@ def get_dag(self, dag_id, session: Session = None):
dag_id in self.dags_last_fetched
and timezone.utcnow() > self.dags_last_fetched[dag_id] +
min_serialized_dag_fetch_secs
):
+ sd_latest_version =
SerializedDagModel.get_latest_version_hash(dag_id=dag_id, session=session)
Review Comment:
you're right. I merged the two queries into a single one in a new method.
From a quick look around, `get_last_updated_datetime` does not seems to be used
anymore, is it fine to remove it in this PR?
--
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: commits-unsubscr...@airflow.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
