You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by fo...@apache.org on 2018/03/04 17:13:58 UTC
incubator-airflow git commit: [AIRFLOW-2129] Presto hook calls
_parse_exception_message but defines _get_pretty_exception_message
Repository: incubator-airflow
Updated Branches:
refs/heads/master 664c963c4 -> 1ac4d07d0
[AIRFLOW-2129] Presto hook calls _parse_exception_message but defines _get_pretty_exception_message
Closes #3094 from feng-tao/airflow-2129
Project: http://git-wip-us.apache.org/repos/asf/incubator-airflow/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-airflow/commit/1ac4d07d
Tree: http://git-wip-us.apache.org/repos/asf/incubator-airflow/tree/1ac4d07d
Diff: http://git-wip-us.apache.org/repos/asf/incubator-airflow/diff/1ac4d07d
Branch: refs/heads/master
Commit: 1ac4d07d0904d32f3b0b58f2ef3b8d44d796b4d0
Parents: 664c963
Author: Tao feng <tf...@lyft.com>
Authored: Sun Mar 4 18:13:52 2018 +0100
Committer: Fokko Driesprong <fo...@godatadriven.com>
Committed: Sun Mar 4 18:13:52 2018 +0100
----------------------------------------------------------------------
airflow/hooks/presto_hook.py | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-airflow/blob/1ac4d07d/airflow/hooks/presto_hook.py
----------------------------------------------------------------------
diff --git a/airflow/hooks/presto_hook.py b/airflow/hooks/presto_hook.py
index b9f30a6..dc14ab2 100644
--- a/airflow/hooks/presto_hook.py
+++ b/airflow/hooks/presto_hook.py
@@ -71,7 +71,7 @@ class PrestoHook(DbApiHook):
return super(PrestoHook, self).get_records(
self._strip_sql(hql), parameters)
except DatabaseError as e:
- raise PrestoException(self._parse_exception_message(e))
+ raise PrestoException(self._get_pretty_exception_message(e))
def get_first(self, hql, parameters=None):
"""
@@ -82,7 +82,7 @@ class PrestoHook(DbApiHook):
return super(PrestoHook, self).get_first(
self._strip_sql(hql), parameters)
except DatabaseError as e:
- raise PrestoException(self._parse_exception_message(e))
+ raise PrestoException(self._get_pretty_exception_message(e))
def get_pandas_df(self, hql, parameters=None):
"""
@@ -94,7 +94,7 @@ class PrestoHook(DbApiHook):
cursor.execute(self._strip_sql(hql), parameters)
data = cursor.fetchall()
except DatabaseError as e:
- raise PrestoException(self._parse_exception_message(e))
+ raise PrestoException(self._get_pretty_exception_message(e))
column_descriptions = cursor.description
if data:
df = pandas.DataFrame(data)