From 602a405e5eadbc45beeb2ad1ef4547d95a75c3a5 Mon Sep 17 00:00:00 2001 From: kalyanr Date: Sun, 7 Apr 2024 19:05:53 +0530 Subject: [PATCH 1/3] update docstring for DagBag class --- airflow/models/dagbag.py | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/airflow/models/dagbag.py b/airflow/models/dagbag.py index ce9bf5587be80..7d7edff723ea1 100644 --- a/airflow/models/dagbag.py +++ b/airflow/models/dagbag.py @@ -89,11 +89,16 @@ class DagBag(LoggingMixin): :param dag_folder: the folder to scan to find DAGs :param include_examples: whether to include the examples that ship with airflow or not + :param safe_mode: when ``False``, scans all python modules for dags. + When ``True`` uses heuristics(files containing ``DAG`` and ``airflow`` strings ) to filter + python modules to scan for dags. :param read_dags_from_db: Read DAGs from DB if ``True`` is passed. If ``False`` DAGs are read from python files. + :param store_serialized_dags: deprecated parameter, same effect as `read_dags_from_db` :param load_op_links: Should the extra operator link be loaded via plugins when de-serializing the DAG? This flag is set to False in Scheduler so that Extra Operator links are not loaded to not run User code in Scheduler. + :param collect_dags: when True, collects dags during class initialization. """ def __init__( From 17f164ce7a588506f0f8000e85d47fdfd8b38963 Mon Sep 17 00:00:00 2001 From: kalyanr Date: Mon, 8 Apr 2024 06:22:25 +0530 Subject: [PATCH 2/3] break long line --- airflow/models/dagbag.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/airflow/models/dagbag.py b/airflow/models/dagbag.py index 7d7edff723ea1..58c737cffc959 100644 --- a/airflow/models/dagbag.py +++ b/airflow/models/dagbag.py @@ -90,8 +90,8 @@ class DagBag(LoggingMixin): :param include_examples: whether to include the examples that ship with airflow or not :param safe_mode: when ``False``, scans all python modules for dags. - When ``True`` uses heuristics(files containing ``DAG`` and ``airflow`` strings ) to filter - python modules to scan for dags. + When ``True`` uses heuristics(files containing ``DAG`` and ``airflow`` strings ) + to filter python modules to scan for dags. :param read_dags_from_db: Read DAGs from DB if ``True`` is passed. If ``False`` DAGs are read from python files. :param store_serialized_dags: deprecated parameter, same effect as `read_dags_from_db` From 6f9636944a47ac1db6241e915fd35b46675caa5d Mon Sep 17 00:00:00 2001 From: kalyanr Date: Mon, 8 Apr 2024 12:40:24 +0530 Subject: [PATCH 3/3] fix space Signed-off-by: kalyanr --- airflow/models/dagbag.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/airflow/models/dagbag.py b/airflow/models/dagbag.py index 58c737cffc959..1902c985be771 100644 --- a/airflow/models/dagbag.py +++ b/airflow/models/dagbag.py @@ -90,7 +90,7 @@ class DagBag(LoggingMixin): :param include_examples: whether to include the examples that ship with airflow or not :param safe_mode: when ``False``, scans all python modules for dags. - When ``True`` uses heuristics(files containing ``DAG`` and ``airflow`` strings ) + When ``True`` uses heuristics (files containing ``DAG`` and ``airflow`` strings) to filter python modules to scan for dags. :param read_dags_from_db: Read DAGs from DB if ``True`` is passed. If ``False`` DAGs are read from python files.