You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by po...@apache.org on 2026/01/21 00:06:55 UTC

(airflow) branch v3-1-test updated: [v3-1-test] apply gc.freeze in dag-processor (#60505) (#60845)

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] <41...@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 <48...@users.noreply.github.com>
---
 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):