diff --git a/ibis-server/app/model/__init__.py b/ibis-server/app/model/__init__.py index 444ad2b0d..40daf7e66 100644 --- a/ibis-server/app/model/__init__.py +++ b/ibis-server/app/model/__init__.py @@ -49,10 +49,6 @@ class QuerySnowflakeDTO(QueryDTO): class QueryDruidDTO(QueryDTO): connection_info: DruidConnectionInfo = connection_info_field -class QueryDruidDTO(QueryDTO): - connection_info: DruidConnectionInfo = connection_info_field - - class QueryTrinoDTO(QueryDTO): connection_info: ConnectionUrl | TrinoConnectionInfo = connection_info_field @@ -86,12 +82,6 @@ class DruidConnectionInfo(BaseModel): port: SecretStr = Field(examples=[8082]) path: str -class DruidConnectionInfo(BaseModel): - host: SecretStr = Field(examples=["localhost"]) - port: SecretStr = Field(examples=[8082]) - path: str - - class MSSqlConnectionInfo(BaseModel): host: SecretStr port: SecretStr diff --git a/ibis-server/app/model/data_source.py b/ibis-server/app/model/data_source.py index 646d9dc88..b1338462e 100644 --- a/ibis-server/app/model/data_source.py +++ b/ibis-server/app/model/data_source.py @@ -121,14 +121,6 @@ def get_druid_connection(info: DruidConnectionInfo) -> BaseBackend: path=info.path, ) - @staticmethod - def get_druid_connection(info: DruidConnectionInfo) -> BaseBackend: - return ibis.druid.connect( - host=info.host.get_secret_value(), - port=int(info.port.get_secret_value()), - path=info.path, - ) - @classmethod def get_mssql_connection(cls, info: MSSqlConnectionInfo) -> BaseBackend: return ibis.mssql.connect(