diff --git a/src/preset_cli/cli/superset/sync/dbt/datasets.py b/src/preset_cli/cli/superset/sync/dbt/datasets.py index 2d028667..e1d0ac4c 100644 --- a/src/preset_cli/cli/superset/sync/dbt/datasets.py +++ b/src/preset_cli/cli/superset/sync/dbt/datasets.py @@ -69,7 +69,12 @@ def create_dataset( else: engine = create_engine(url) quote = engine.dialect.identifier_preparer.quote - source = ".".join(quote(model[key]) for key in ("database", "schema", "name")) + table_name = model.get("alias") or model["name"] + source = ".".join([ + quote(model["database"]), + quote(model["schema"]), + quote(table_name) + ]) kwargs = { "database": database["id"], "schema": model["schema"],