diff --git a/airflow/models.py b/airflow/models.py index c307a1254e4e1..64d0d06a245c6 100644 --- a/airflow/models.py +++ b/airflow/models.py @@ -311,8 +311,8 @@ def collect_dags( [re.findall(p, filepath) for p in patterns]): self.process_file( filepath, only_if_updated=only_if_updated) - except: - pass + except Exception as e: + logging.warning(e) def deactivate_inactive_dags(self): active_dag_ids = [dag.dag_id for dag in list(self.dags.values())]