Merge pull request #968 from DalgoT4D/967-elementary-profile-for-bq-d…

…oesnt-containschema copy `dataset` to `schema`
DalgoT4D · Feb 16, 2025 · c77cfb7 · c77cfb7
2 parents 1e05932 + 570617c
commit c77cfb7
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/ddpui/ddpdbt/elementary_service.py b/ddpui/ddpdbt/elementary_service.py
@@ -237,6 +237,10 @@ def create_elementary_profile(org: Org):
         logger.info("read dbt profile from %s", dbt_profile_file)
 
     target = elementary_profile["elementary"].get("target", "default")
+    if elementary_profile["elementary"]["outputs"][target]["type"] == "bigquery":
+        elementary_profile["elementary"]["outputs"][target]["schema"] = elementary_profile[
+            "elementary"
+        ]["outputs"][target]["dataset"]
     elementary_schema = elementary_profile["elementary"]["outputs"][target]["schema"]
     elementary_profile["elementary"]["outputs"][target] = dbt_profile[dbt_profile_name]["outputs"][
         dbt_profiles_target