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/10 07:57:32 UTC
incubator-airflow git commit: [AIRFLOW-1794] Remove uses of
Exception.message for Python 3
Repository: incubator-airflow
Updated Branches:
refs/heads/master f14f8558b -> f5f770125
[AIRFLOW-1794] Remove uses of Exception.message for Python 3
Closes #2766 from dhuang/AIRFLOW-1794
Project: http://git-wip-us.apache.org/repos/asf/incubator-airflow/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-airflow/commit/f5f77012
Tree: http://git-wip-us.apache.org/repos/asf/incubator-airflow/tree/f5f77012
Diff: http://git-wip-us.apache.org/repos/asf/incubator-airflow/diff/f5f77012
Branch: refs/heads/master
Commit: f5f7701258f858698562579cbfb4e1934056e009
Parents: f14f855
Author: Daniel Huang <dx...@gmail.com>
Authored: Fri Nov 10 08:57:22 2017 +0100
Committer: Bolke de Bruin <bo...@xs4all.nl>
Committed: Fri Nov 10 08:57:22 2017 +0100
----------------------------------------------------------------------
airflow/hooks/webhdfs_hook.py | 2 +-
airflow/www/views.py | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-airflow/blob/f5f77012/airflow/hooks/webhdfs_hook.py
----------------------------------------------------------------------
diff --git a/airflow/hooks/webhdfs_hook.py b/airflow/hooks/webhdfs_hook.py
index 4510d29..35d4e33 100644
--- a/airflow/hooks/webhdfs_hook.py
+++ b/airflow/hooks/webhdfs_hook.py
@@ -61,7 +61,7 @@ class WebHDFSHook(BaseHook):
return client
except HdfsError as e:
self.log.debug(
- "Read operation on namenode {nn.host} failed witg error: {e.message}".format(**locals())
+ "Read operation on namenode {nn.host} failed with error: {e}".format(**locals())
)
nn_hosts = [c.host for c in nn_connections]
no_nn_error = "Read operations failed on the namenodes below:\n{}".format("\n".join(nn_hosts))
http://git-wip-us.apache.org/repos/asf/incubator-airflow/blob/f5f77012/airflow/www/views.py
----------------------------------------------------------------------
diff --git a/airflow/www/views.py b/airflow/www/views.py
index a6d788e..c7869c5 100644
--- a/airflow/www/views.py
+++ b/airflow/www/views.py
@@ -712,7 +712,7 @@ class Airflow(BaseView):
logs = handler.read(ti)
except AttributeError as e:
logs = ["Task log handler {} does not support read logs.\n{}\n" \
- .format(task_log_reader, e.message)]
+ .format(task_log_reader, str(e))]
for i, log in enumerate(logs):
if PY2 and not isinstance(log, unicode):