增加连接失败报错

app/core/datasource/hive.py

@@ -117,7 +117,7 @@ class HiveDS(DataSourceBase):
             # logger.info(res)
         except Exception as e:
             logger.error(e)
-
+            raise Exception('hive 连接失败')
         finally:
             if conn is not None:
                 conn.close()

app/core/datasource/mysql.py

@@ -74,7 +74,7 @@ class MysqlDS(DataSourceBase):
             logger.info(res)
         except Error as e:
             logger.error(e)
-
+            raise Exception('mysql 连接失败')
         finally:
             if conn is not None and conn.is_connected():
                 conn.close()