You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by bo...@apache.org on 2017/11/26 14:38:49 UTC
incubator-airflow git commit: [AIRFLOW-1838] Properly log
collect_dags exception
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 <fo...@godatadriven.com>
Authored: Sun Nov 26 15:38:41 2017 +0100
Committer: Bolke de Bruin <bo...@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(