diff --git a/airflow-core/src/airflow/dag_processing/manager.py b/airflow-core/src/airflow/dag_processing/manager.py index f6bf7891945ce..fed39d77675f9 100644 --- a/airflow-core/src/airflow/dag_processing/manager.py +++ b/airflow-core/src/airflow/dag_processing/manager.py @@ -21,6 +21,7 @@ import contextlib import functools +import gc import inspect import logging import os @@ -279,6 +280,9 @@ def run(self): 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):