Repository: incubator-airflow Updated Branches: refs/heads/master 5933fca1c -> 08e28ab88
[AIRFLOW-739] Set pickle_info log to debug pickle_info tries to pickle. If it catches an exception it is assumed that the DAG is not pickable and continues. Therefore, it should log to debug instead and not provide a full stacktrace. Closes #1975 from bolkedebruin/AIRFLOW-739 Project: http://git-wip-us.apache.org/repos/asf/incubator-airflow/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-airflow/commit/08e28ab8 Tree: http://git-wip-us.apache.org/repos/asf/incubator-airflow/tree/08e28ab8 Diff: http://git-wip-us.apache.org/repos/asf/incubator-airflow/diff/08e28ab8 Branch: refs/heads/master Commit: 08e28ab889dee158dd8ed6d2dab6a5016e293ce5 Parents: 5933fca Author: Bolke de Bruin <[email protected]> Authored: Fri Jan 20 16:41:50 2017 +0100 Committer: Bolke de Bruin <[email protected]> Committed: Fri Jan 20 16:42:02 2017 +0100 ---------------------------------------------------------------------- airflow/models.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-airflow/blob/08e28ab8/airflow/models.py ---------------------------------------------------------------------- diff --git a/airflow/models.py b/airflow/models.py index a16603d..95c40a9 100755 --- a/airflow/models.py +++ b/airflow/models.py @@ -3149,7 +3149,7 @@ class DAG(BaseDag, LoggingMixin): d['pickle_len'] = len(pickled) d['pickling_duration'] = "{}".format(datetime.now() - dttm) except Exception as e: - logging.exception(e) + logging.debug(e) d['is_picklable'] = False d['stacktrace'] = traceback.format_exc() return d
