From 18f5b989a4ee7854719308599206f2c77e3d4c1c Mon Sep 17 00:00:00 2001 From: "phong.nt2" Date: Mon, 23 Oct 2023 11:25:34 +0700 Subject: [PATCH] fix(superset/sync/dbt-core): dataset's sql does not handle model's alias --- src/preset_cli/cli/superset/sync/dbt/datasets.py | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) 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"],