refactor

app/core/hive.py → app/core/ds/hive.py

@@ -1,4 +1,4 @@
-from app.core.datasource import DataSourceBase
+from app.core.ds.datasource import DataSourceBase
 from pyhive import hive
 from pyhive.exc import DatabaseError
 from configs.logging import logger

app/core/mysql.py → app/core/ds/mysql.py

@@ -1,6 +1,6 @@
 
 from dataclasses import dataclass
-from app.core.datasource import DataSourceBase
+from app.core.ds.datasource import DataSourceBase
 from mysql import connector
 from mysql.connector import Error
 from sqlalchemy import create_engine

app/crud/job_jdbc_datasource.py

@@ -1,7 +1,7 @@
 import time
 from typing import List
 from sqlalchemy.orm import Session
-from app.core.datasource import DataSrouceFactory
+from app.core.ds.datasource import DataSrouceFactory
 import app.schemas as schemas
 import  app.models as models