This is an automated email from the ASF dual-hosted git repository.
amoghdesai 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 96b5be9cf36 Clarify logs when a DAG is being processed in DPM (#65196)
96b5be9cf36 is described below
commit 96b5be9cf36728ca2deebbd45201ad2ee340e43c
Author: Amogh Desai <[email protected]>
AuthorDate: Wed Apr 15 12:33:49 2026 +0530
Clarify logs when a DAG is being processed in DPM (#65196)
---
airflow-core/src/airflow/dag_processing/manager.py | 5 ++++-
1 file changed, 4 insertions(+), 1 deletion(-)
diff --git a/airflow-core/src/airflow/dag_processing/manager.py
b/airflow-core/src/airflow/dag_processing/manager.py
index 76f641da0f3..7fcafa98bea 100644
--- a/airflow-core/src/airflow/dag_processing/manager.py
+++ b/airflow-core/src/airflow/dag_processing/manager.py
@@ -1220,8 +1220,11 @@ class DagFileProcessorManager(LoggingMixin):
if self.log.isEnabledFor(logging.DEBUG):
for path, processor in self._processors.items():
+ now_monotonic = time.monotonic()
self.log.debug(
- "File path %s is still being processed (started: %s)",
path, processor.start_time
+ "File path %s is still being processed (duration: %.2fs)",
+ path,
+ now_monotonic - processor.start_time,
)
self.log.debug(
