From def28c1fb2ab55e7c2761a39047a499e24b5e4c3 Mon Sep 17 00:00:00 2001 From: "Zikes, Jan" Date: Wed, 2 Dec 2015 17:18:59 +0100 Subject: [PATCH 1/2] added at least to show possible exception in searching for DAGs --- airflow/models.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/airflow/models.py b/airflow/models.py index c307a1254e4e1..166a3d3e13e9e 100644 --- a/airflow/models.py +++ b/airflow/models.py @@ -311,7 +311,8 @@ def collect_dags( [re.findall(p, filepath) for p in patterns]): self.process_file( filepath, only_if_updated=only_if_updated) - except: + except Exception as e: + logging.warning(e) pass def deactivate_inactive_dags(self): From 638f325a700e8e261608b476a134dc8c0243408d Mon Sep 17 00:00:00 2001 From: "Zikes, Jan" Date: Wed, 2 Dec 2015 21:43:05 +0100 Subject: [PATCH 2/2] removed pass --- airflow/models.py | 1 - 1 file changed, 1 deletion(-) diff --git a/airflow/models.py b/airflow/models.py index 166a3d3e13e9e..64d0d06a245c6 100644 --- a/airflow/models.py +++ b/airflow/models.py @@ -313,7 +313,6 @@ def collect_dags( filepath, only_if_updated=only_if_updated) except Exception as e: logging.warning(e) - pass def deactivate_inactive_dags(self): active_dag_ids = [dag.dag_id for dag in list(self.dags.values())]