follow symlinks in dag_folder and plugins_folder

Arkoniak · Aug 23, 2015 · 80caf6a · 80caf6a
1 parent 8496164
commit 80caf6a
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/airflow/models.py b/airflow/models.py
@@ -233,7 +233,7 @@ def collect_dags(
             self.process_file(dag_folder, only_if_updated=only_if_updated)
         elif os.path.isdir(dag_folder):
             patterns = []
-            for root, dirs, files in os.walk(dag_folder):
+            for root, dirs, files in os.walk(dag_folder, followlinks=True):
                 ignore_file = [f for f in files if f == '.airflowignore']
                 if ignore_file:
                     f = open(os.path.join(root, ignore_file[0]), 'r')

diff --git a/airflow/plugins_manager.py b/airflow/plugins_manager.py
@@ -35,7 +35,7 @@ def validate(cls):
 plugins = []
 
 # Crawl through the plugins folder to find AirflowPlugin derivatives
-for root, dirs, files in os.walk(plugins_folder):
+for root, dirs, files in os.walk(plugins_folder, followlinks=True):
     for f in files:
         try:
             filepath = os.path.join(root, f)