datahub/metadata-ingestion/tests/unit/test_druid_source.py
Rasnar 5f5e395c90
Fix platform instance support on Druid ingestion (#12716)
Co-authored-by: rasnar <11248833+Rasnar@users.noreply.github.com>
Co-authored-by: Sergio Gómez Villamor <sgomezvillamor@gmail.com>
2025-02-26 08:36:06 +01:00

14 lines
401 B
Python

from datahub.ingestion.source.sql.druid import DruidConfig
def test_druid_uri():
config = DruidConfig.parse_obj({"host_port": "localhost:8082"})
assert config.get_sql_alchemy_url() == "druid://localhost:8082/druid/v2/sql/"
def test_druid_get_identifier():
config = DruidConfig.parse_obj({"host_port": "localhost:8082"})
assert config.get_identifier("schema", "table") == "table"