diff --git a/superset/db_engine_specs.py b/superset/db_engine_specs.py
index 5f67ec6d838ea..0fe988997081d 100644
--- a/superset/db_engine_specs.py
+++ b/superset/db_engine_specs.py
@@ -681,6 +681,14 @@ def adjust_database_uri(cls, uri, selected_schema=None):
             uri.database = selected_schema
         return uri
 
+    @classmethod
+    def extract_error_message(cls, e):
+        try:
+            msg = e.message.status.errorMessage
+        except:
+            msg = str(e)
+        return msg
+
     @classmethod
     def progress(cls, log_lines):
         total_jobs = 1  # assuming there's at least 1 job