diff --git a/models/staging/hubspot_staging/stg_rag_hubspot__owner.sql b/models/staging/hubspot_staging/stg_rag_hubspot__owner.sql index fa06618..62a5175 100644 --- a/models/staging/hubspot_staging/stg_rag_hubspot__owner.sql +++ b/models/staging/hubspot_staging/stg_rag_hubspot__owner.sql @@ -21,7 +21,7 @@ fields as ( select {{ fivetran_utils.fill_staging_columns( - source_columns=adapter.get_columns_in_relation(source('rag_hubspot','contact')), + source_columns=adapter.get_columns_in_relation(source('rag_hubspot','owner')), staging_columns=get_hubspot_owner_columns() ) }}