diff --git a/superset/db_engine_specs.py b/superset/db_engine_specs.py index 4d373dff5a0de..6c21206a3cb49 100644 --- a/superset/db_engine_specs.py +++ b/superset/db_engine_specs.py @@ -541,12 +541,6 @@ class PrestoEngineSpec(BaseEngineSpec): "date_add('day', 1, CAST({col} AS TIMESTAMP))))"), ) - @classmethod - def patch(cls): - from pyhive import presto - from superset.db_engines import presto as patched_presto - presto.Cursor.cancel = patched_presto.cancel - @classmethod def adjust_database_uri(cls, uri, selected_schema=None): database = uri.database diff --git a/superset/db_engines/presto.py b/superset/db_engines/presto.py deleted file mode 100644 index 724cb9e08fe96..0000000000000 --- a/superset/db_engines/presto.py +++ /dev/null @@ -1,27 +0,0 @@ -# -*- coding: utf-8 -*- -from __future__ import absolute_import -from __future__ import division -from __future__ import print_function -from __future__ import unicode_literals - -from pyhive import presto - - -# TODO(bogdan): Remove this when new pyhive release will be available. -def cancel(self): - if self._state == self._STATE_NONE: - raise presto.ProgrammingError('No query yet') - if self._nextUri is None: - assert self._state == self._STATE_FINISHED, \ - 'Should be finished if nextUri is None' - return - - response = presto.requests.delete(self._nextUri) - - # pylint: disable=no-member - if response.status_code != presto.requests.codes.no_content: - fmt = 'Unexpected status code after cancel {}\n{}' - raise presto.OperationalError( - fmt.format(response.status_code, response.content)) - self._state = self._STATE_FINISHED - return