This is an automated email from the ASF dual-hosted git repository.
potiuk 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 48d7ac5f448 Improve DAG processor timeout logging clarity (#62328)
48d7ac5f448 is described below
commit 48d7ac5f4488eedbe3e45ef7af0b851d05af58dd
Author: Andrii Roiko <[email protected]>
AuthorDate: Mon Mar 9 22:06:48 2026 +0200
Improve DAG processor timeout logging clarity (#62328)
* Add 'seconds' to logging message
* Improve DAG processor timeout logging clarity
* Use floats in log message
---
airflow-core/src/airflow/dag_processing/manager.py | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git a/airflow-core/src/airflow/dag_processing/manager.py
b/airflow-core/src/airflow/dag_processing/manager.py
index 6131248980e..5ad3618048f 100644
--- a/airflow-core/src/airflow/dag_processing/manager.py
+++ b/airflow-core/src/airflow/dag_processing/manager.py
@@ -1159,10 +1159,11 @@ class DagFileProcessorManager(LoggingMixin):
duration = now - processor.start_time
if duration > self.processor_timeout:
self.log.error(
- "Processor for %s with PID %s started %d ago killing it.",
+ "Processor for %s with PID %s has been running for %.2f
seconds, exceeding the timeout of %.2f seconds. Killing it!",
file,
processor.pid,
duration,
+ self.processor_timeout,
)
file_name = str(file.rel_path)
Stats.decr("dag_processing.processes", tags={"file_path":
file_name, "action": "timeout"})
