This is an automated email from the ASF dual-hosted git repository.
jscheffl pushed a commit to branch v3-0-test
in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/v3-0-test by this push:
new 2d959f939ca [v3-0-test] Fixes DagProcessor stats log | process
durations now use time.monotonic() (#50316) (#50370)
2d959f939ca is described below
commit 2d959f939ca99b38c8c08a1bb4d05c77d7f7f94b
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Thu May 8 22:05:36 2025 +0200
[v3-0-test] Fixes DagProcessor stats log | process durations now use
time.monotonic() (#50316) (#50370)
(cherry picked from commit 4f4f9bd33926171d240345dfae82853914a08b7d)
Co-authored-by: ayush3singh <[email protected]>
---
airflow-core/src/airflow/dag_processing/manager.py | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/airflow-core/src/airflow/dag_processing/manager.py
b/airflow-core/src/airflow/dag_processing/manager.py
index 324813cec38..b5ec51039c3 100644
--- a/airflow-core/src/airflow/dag_processing/manager.py
+++ b/airflow-core/src/airflow/dag_processing/manager.py
@@ -679,7 +679,7 @@ class DagFileProcessorManager(LoggingMixin):
rows = []
utcnow = timezone.utcnow()
- now = time.time()
+ now = time.monotonic()
for files in known_files.values():
for file in files:
@@ -806,7 +806,7 @@ class DagFileProcessorManager(LoggingMixin):
# Collect the DAGS and import errors into the DB, emit metrics etc.
self._file_stats[file] = process_parse_results(
- run_duration=time.time() - proc.start_time,
+ run_duration=time.monotonic() - proc.start_time,
finish_time=timezone.utcnow(),
run_count=self._file_stats[file].run_count,
bundle_name=file.bundle_name,
