This is an automated email from the ASF dual-hosted git repository.
turaga pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/main by this push:
new b9a23eec792 improved a log message in the dag parsing. (#60789)
b9a23eec792 is described below
commit b9a23eec7923aa073180c69c695c2d284974421a
Author: Nataneljpwd <[email protected]>
AuthorDate: Mon Jan 19 19:43:37 2026 +0000
improved a log message in the dag parsing. (#60789)
---
airflow-core/src/airflow/dag_processing/manager.py | 7 ++++++-
1 file changed, 6 insertions(+), 1 deletion(-)
diff --git a/airflow-core/src/airflow/dag_processing/manager.py
b/airflow-core/src/airflow/dag_processing/manager.py
index b9b2cfcdee8..b734607e136 100644
--- a/airflow-core/src/airflow/dag_processing/manager.py
+++ b/airflow-core/src/airflow/dag_processing/manager.py
@@ -324,7 +324,12 @@ class DagFileProcessorManager(LoggingMixin):
file_info = DagFileInfo(rel_path=Path(dag.relative_fileloc),
bundle_name=dag.bundle_name)
if last_finish_time := last_parsed.get(file_info, None):
if dag.last_parsed_time +
timedelta(seconds=self.stale_dag_threshold) < last_finish_time:
- self.log.info("DAG %s is missing and will be
deactivated.", dag.dag_id)
+ self.log.info(
+ "Deactivating stale DAG %s. Not parsed for %s seconds
(last parsed: %s).",
+ dag.dag_id,
+ int((last_finish_time -
dag.last_parsed_time).total_seconds()),
+ dag.last_parsed_time,
+ )
to_deactivate.add(dag.dag_id)
if to_deactivate:
