airflow-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From bo...@apache.org
Subject incubator-airflow git commit: [AIRFLOW-1838] Properly log collect_dags exception
Date Sun, 26 Nov 2017 14:38:49 GMT
Repository: incubator-airflow
Updated Branches:
  refs/heads/master 4247ff022 -> f5df0d343


[AIRFLOW-1838] Properly log collect_dags exception

As a user it would be nice to properly log the
exceptions
thrown in the collect_dags function to debug the
faulty dags

Closes #2803 from Fokko/AIRFLOW-1838-Properly-log-
collect-dags-exception


Project: http://git-wip-us.apache.org/repos/asf/incubator-airflow/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-airflow/commit/f5df0d34
Tree: http://git-wip-us.apache.org/repos/asf/incubator-airflow/tree/f5df0d34
Diff: http://git-wip-us.apache.org/repos/asf/incubator-airflow/diff/f5df0d34

Branch: refs/heads/master
Commit: f5df0d3437e206e2a8bc9586c4fc2383fa0cf043
Parents: 4247ff0
Author: Fokko Driesprong <fokkodriesprong@godatadriven.com>
Authored: Sun Nov 26 15:38:41 2017 +0100
Committer: Bolke de Bruin <bolke@xs4all.nl>
Committed: Sun Nov 26 15:38:41 2017 +0100

----------------------------------------------------------------------
 airflow/models.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-airflow/blob/f5df0d34/airflow/models.py
----------------------------------------------------------------------
diff --git a/airflow/models.py b/airflow/models.py
index ab83563..d34223d 100755
--- a/airflow/models.py
+++ b/airflow/models.py
@@ -441,7 +441,7 @@ class DagBag(BaseDagBag, LoggingMixin):
                                 str([dag.dag_id for dag in found_dags]),
                             ))
                     except Exception as e:
-                        self.log.warning(e)
+                        self.log.exception(e)
         Stats.gauge(
             'collect_dags', (datetime.utcnow() - start_dttm).total_seconds(), 1)
         Stats.gauge(


Mime
View raw message