This is an automated email from the ASF dual-hosted git repository.
eladkal pushed a commit to branch v3-1-test
in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/v3-1-test by this push:
new 41dd6210199 [v3-1-test] improved a log message in the dag parsing.
(#60789) (#60814)
41dd6210199 is described below
commit 41dd6210199b292393c93ab48ad990d925522b7d
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Tue Jan 20 13:08:45 2026 +0200
[v3-1-test] improved a log message in the dag parsing. (#60789) (#60814)
(cherry picked from commit b9a23eec7923aa073180c69c695c2d284974421a)
Co-authored-by: Nataneljpwd <[email protected]>
---
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 c362112646d..f6bf7891945 100644
--- a/airflow-core/src/airflow/dag_processing/manager.py
+++ b/airflow-core/src/airflow/dag_processing/manager.py
@@ -320,7 +320,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:
