fix models

airbytehq · Sep 8, 2024 · 13dfcd6 · 13dfcd6
1 parent 6f02808
commit 13dfcd6
Show file tree

Hide file tree

Showing 3 changed files with 9 additions and 9 deletions.
diff --git a/connectors/source_hubspot/models/fivetran_converter/contact_list_member.sql b/connectors/source_hubspot/models/fivetran_converter/contact_list_member.sql
@@ -4,18 +4,18 @@ SELECT
     {% if target.type == "postgres" %}
         "user-id" AS id,
     {% elif target.type == "snowflake" %}
-        `"user-id"` AS id,
+        "user-id" AS id,
     {% elif target.type == "bigquery" %}
-        `user-id` AS id,
+        `user_id` AS id,
     {% endif %}
     vid_to_merge,
     timestamp AS merged_timestamp,
     {% if target.type == "postgres" %}
         "user-id" AS user_id,
     {% elif target.type == "snowflake" %}
-        `"user-id"` AS user_id,
+        "user-id" AS user_id,
     {% elif target.type == "bigquery" %}
-        `user-id` AS user_id,
+        `user_id` AS user_id,
     {% endif %}
     first_name AS user_first_name,
     last_name AS user_last_name

diff --git a/connectors/source_hubspot/models/fivetran_converter/contact_merged_audit.sql b/connectors/source_hubspot/models/fivetran_converter/contact_merged_audit.sql
@@ -18,7 +18,7 @@ FROM
 
 SELECT
     {{ dbt.current_timestamp() }} AS fivetran_synced,
-    `"user-id"`::STRING AS user_id,
+    "user-id" AS user_id,
     vid_to_merge AS contact_id,
     entity_id,
     first_name,
@@ -34,14 +34,14 @@ FROM
 
 SELECT
     {{ dbt.current_timestamp() }} AS fivetran_synced,
-    `user-id` AS user_id,
+    `user_id` AS user_id,
     vid_to_merge AS contact_id,
     entity_id,
     first_name,
     last_name,
     num_properties_moved,
     timestamp_at,
-    `user-id` AS original_user_id,
+    `user_id` AS original_user_id,
     vid_to_merge
 FROM 
     {{ source('source_hubspot', 'contacts_merged_audit') }}

diff --git a/connectors/source_hubspot/models/fivetran_converter/contact_property_history.sql b/connectors/source_hubspot/models/fivetran_converter/contact_property_history.sql
@@ -5,9 +5,9 @@ SELECT
     {% if target.type == "postgres" %}
         "source-id" AS change_source,
     {% elif target.type == "snowflake" %}
-        `"source-id"`::STRING AS change_source,
+        "source-id" AS change_source,
     {% elif target.type == "bigquery" %}
-        `source-id` AS change_source,
+        `source_id` AS change_source,
     {% endif %}
     properties_hs_created_by_user_id AS change_source_id,
     CAST(timestamp AS {{ dbt.type_timestamp() }}) AS change_timestamp,