This is an automated email from the ASF dual-hosted git repository.
potiuk 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 aa566c39e5c [v3-1-test] apply gc.freeze in dag-processor (#60505)
(#60845)
aa566c39e5c is described below
commit aa566c39e5caa4695c675b842ba65774f7a1c651
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Wed Jan 21 01:06:47 2026 +0100
[v3-1-test] apply gc.freeze in dag-processor (#60505) (#60845)
(cherry picked from commit 9d31db37ef5c2c00258bd2eeeedfb34ce0d68a4a)
Co-authored-by: Jeongwoo Do <[email protected]>
---
airflow-core/src/airflow/dag_processing/manager.py | 4 ++++
1 file changed, 4 insertions(+)
diff --git a/airflow-core/src/airflow/dag_processing/manager.py
b/airflow-core/src/airflow/dag_processing/manager.py
index f6bf7891945..fed39d77675 100644
--- a/airflow-core/src/airflow/dag_processing/manager.py
+++ b/airflow-core/src/airflow/dag_processing/manager.py
@@ -21,6 +21,7 @@ from __future__ import annotations
import contextlib
import functools
+import gc
import inspect
import logging
import os
@@ -279,6 +280,9 @@ class DagFileProcessorManager(LoggingMixin):
self._symlink_latest_log_directory()
+ # To prevent COW in forked process parsing dag file
+ gc.freeze()
+
return self._run_parsing_loop()
def _scan_stale_dags(self):
