fivetran · fivetran-sheringuyen · Mar 23, 2023 · Feb 4, 2023 · Feb 6, 2023 · Feb 6, 2023
diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -1,3 +1,18 @@
+# dbt_linkedin_source v0.7.0
+## 🚨 Breaking Changes 🚨
+Due to Linkedin Ads API [change in January 2023](https://learn.microsoft.com/en-us/linkedin/marketing/integrations/recent-changes?view=li-lms-2022-12#january-2023), there have been updates in the Linkedin Ads Fivetran Connector and therefore, updates to this Linkedin package. 
+
+The following fields have been completely deprecated in the `stg_linkedin_ads__creative_history` model:
+- `type`
+- `call_to_action_label_type`
+- `version_tag`
+
+## Updates
+The following legacy fields have been updated respectively in the connector and [PR #](LINK HERE) includes the below modifications:
+- `last_modified_time` has been updated to `last_modified_at`
+- `created_time` has been updated to `created_at`
+- `status` has been updated to `intended_status`
+
 # dbt_linkedin_source v0.6.0
 
 ## 🚨 Breaking Changes 🚨:

diff --git a/dbt_project.yml b/dbt_project.yml
@@ -1,5 +1,5 @@
 name: 'linkedin_source'
-version: '0.6.0'
+version: '0.7.0'
 config-version: 2
 require-dbt-version: [">=1.3.0", "<2.0.0"]
 models:

diff --git a/integration_tests/dbt_project.yml b/integration_tests/dbt_project.yml
@@ -1,5 +1,5 @@
 name: 'linkedin_source_integration_tests'
-version: '0.6.0'
+version: '0.7.0'
 profile: 'integration_tests'
 config-version: 2
 
@@ -20,6 +20,8 @@ seeds:
       +column_types:
         created_time: timestamp
         last_modified_time: timestamp
+        created_at: timestamp
+        last_modified_at: timestamp
         click_uri: "{{ 'string' if target.type in ('bigquery','spark','databricks') else 'varchar' }}"
     linkedin_ad_analytics_by_creative_data:
       +column_types:

diff --git a/macros/get_creative_history_columns.sql b/macros/get_creative_history_columns.sql
@@ -1,15 +1,14 @@
 {% macro get_creative_history_columns() %}
 
 {% set columns = [
-    {"name": "call_to_action_label_type", "datatype": dbt.type_string()},
     {"name": "campaign_id", "datatype": dbt.type_int()},
     {"name": "click_uri", "datatype": dbt.type_string()},
     {"name": "created_time", "datatype": dbt.type_timestamp()},
+    {"name": "created_at", "datatype": dbt.type_timestamp()},
     {"name": "id", "datatype": dbt.type_int()},
     {"name": "last_modified_time", "datatype": dbt.type_timestamp()},
-    {"name": "status", "datatype": dbt.type_string()},
-    {"name": "type", "datatype": dbt.type_string()},
-    {"name": "version_tag", "datatype": dbt.type_string()}
+    {"name": "last_modified_at", "datatype": dbt.type_timestamp()},
+    {"name": "intended_status", "datatype": dbt.type_string()},
 ] %}
 
 {{ return(columns) }}

diff --git a/models/src_linkedin.yml b/models/src_linkedin.yml
@@ -45,45 +45,33 @@ sources:
             description: Unique internal ID representing the creative.
 
           - name: last_modified_time
-            description: The timestamp of when the version was updated.
+            description: The timestamp of when the version was updated (Linkedin Ads pre-January 2023 API Update).
 
+          - name: last_modified_at
+            description: The timestamp of when the version was updated (Linkedin Ads post-January 2023 API Update).
+
           - name: created_time
-            description: The timestamp of when the creative was created.
+            description: The timestamp of when the creative was created (Linkedin Ads pre-January 2023 API Update).
+
+          - name: created_at
+            description: The timestamp of when the creative was created (Linkedin Ads post-January 2023 API Update).
 
           - name: campaign_id
             description: The ID of the campaign the creative belongs to.
 
-          - name: status
+          - name: click_uri
+            description: |
+                Required when creative type is TEXT_AD. Maximum character limit of 500 after URL encoding all special characters. 
+                Limit does not include the "https://" prefix.
+
+          - name: intended_status
             description: |
                 ACTIVE - Creative creation is complete and creative is available for review and serve.
                 PAUSED - Creative creation is complete and creative is current, but should temporarily not be served. This status is not valid upon creation.
                 DRAFT - Creative creation is incomplete and may still be edited.
                 ARCHIVED - Creative creation is complete, but creative should not be served and should be separated from non-archived creatives in any UI.
                 CANCELED - Creative is permanently canceled.
 
-          - name: version_tag
-            description: An integer representation of the version of the creative.
-
-          - name: type 
-            description: |
-                TEXT_AD - Text with Sponsored Link to landing page on your site.
-                SPONSORED_STATUS_UPDATE - Sponsored status update from a profile page.
-                SPONSORED_INMAILS - Single message ad delivered to the member's inbox
-                SPONSORED_MESSAGE - Conversation ad containing a tree of pre-determined messages delivered to the member's inbox
-                SPONSORED_VIDEO - Sponsored videos.
-                SPONSORED_UPDATE_CAROUSEL - Sponsored Carousels
-                FOLLOW_COMPANY_V2 - Dynamic Follow Ad
-                SPOTLIGHT_V2 - Dynamic Spotlight Ad
-                JOBS_V2 - Dynamic Job Ad
-
-          - name: click_uri
-            description: |
-                Required when creative type is TEXT_AD. Maximum character limit of 500 after URL encoding all special characters. 
-                Limit does not include the "https://" prefix.
-
-          - name: call_to_action_label_type
-            description: The labeled call-to-action on this ad.
-
       - name: campaign_history
         description: Each record represents a 'version' of a campaign.
         identifier: "{{ var('linkedin_ads_campaign_history_identifier', 'campaign_history') }}"

diff --git a/models/stg_linkedin.yml b/models/stg_linkedin.yml
@@ -61,7 +61,7 @@ models:
     tests:
       - dbt_utils.unique_combination_of_columns:
           combination_of_columns:
-            - version_tag
+            - _fivetran_synced
             - creative_id 
     columns:
       - name: creative_id
@@ -78,23 +78,6 @@ models:
       - name: campaign_id
         description: The ID of the campaign the creative belongs to.
 
-      - name: type
-        description: |
-          TEXT_AD - Text with Sponsored Link to landing page on your site.
-          SPONSORED_STATUS_UPDATE - Sponsored status update from a profile page.
-          SPONSORED_INMAILS - Single message ad delivered to the member's inbox
-          SPONSORED_MESSAGE - Conversation ad containing a tree of pre-determined messages delivered to the member's inbox
-          SPONSORED_VIDEO - Sponsored videos.
-          SPONSORED_UPDATE_CAROUSEL - Sponsored Carousels
-          FOLLOW_COMPANY_V2 - Dynamic Follow Ad
-          SPOTLIGHT_V2 - Dynamic Spotlight Ad
-          JOBS_V2 - Dynamic Job Ad
-
-      - name: version_tag
-        description: An integer representation of the version of the creative.
-        tests:
-          - not_null
-
       - name: status
         description: |
           ACTIVE - Creative creation is complete and creative is available for review and serve.
@@ -132,9 +115,6 @@ models:
       - name: utm_term
         description: The utm_term parameter of the ad, extracted from the `click_uri`.
 
-      - name: call_to_action_label_type
-        description: The labeled call-to-action on this ad.
-
       - name: is_latest_version
         description: Boolean of whether the record is the latest version of the cretive.
 

diff --git a/models/stg_linkedin_ads__creative_history.sql b/models/stg_linkedin_ads__creative_history.sql
@@ -21,14 +21,11 @@ with base as (
     select
         id as creative_id,
         campaign_id,
-        type,
-        cast(version_tag as numeric) as version_tag,
-        status,
+        intended_status as status,
         click_uri,
-        call_to_action_label_type,
-        cast(last_modified_time as {{ dbt.type_timestamp() }}) as last_modified_at,
-        cast(created_time as {{ dbt.type_timestamp() }}) as created_at,
-        row_number() over (partition by id order by last_modified_time desc) = 1 as is_latest_version
+        cast(coalesce(last_modified_at, last_modified_time) as {{ dbt.type_timestamp() }}) as last_modified_at,
+        cast(coalesce(created_at, created_time) as {{ dbt.type_timestamp() }}) as created_at,
+        row_number() over (partition by id order by coalesce(last_modified_at, last_modified_time) desc) = 1 as is_latest_version
 
     from macro