Adds options to which models are included

CHANGELOG.md

@@ -1,3 +1,22 @@
+# dbt_fivetran_log v0.5.5
+## Fixes
+- Added the option to disable some models that are not available depending on your Fivetran license. In dbt_project.yml you can now change these flags to disable parts of the package
+  - fivetran_log_account_membership
+  - fivetran_log_active_volume
+  - fivetran_log_credits_used
+  - fivetran_log_destination_membership
+  - fivetran_log_user
+
+  Include this in your dbt_project.yml file
+
+  ```
+  fivetran_log_account_membership: false # Disables account membership models
+  fivetran_log_active_volume: false # Disables account membership models
+  fivetran_log_credits_used: false # Disables account membership models
+  fivetran_log_destination_membership: false # Disables account membership models
+  fivetran_log_user: false # Disables account membership models
+  ```
+
 # dbt_fivetran_log v0.5.4
 ## Fixes
 - The unique combination of columns test within the `fivetran_log__schema_changelog` model has been updated to also check the `message_data` field. This is needed as schema changelog events may now sync at the same time. ([#51](https://github.com/fivetran/dbt_fivetran_log/pull/51))

dbt_project.yml

@@ -1,7 +1,7 @@
 config-version: 2
 
 name: 'fivetran_log'
-version: '0.5.4'
+version: '0.5.5'
 
 require-dbt-version: [">=1.0.0", "<2.0.0"]
 

models/fivetran_log__credit_mar_destination_history.sql

@@ -1,3 +1,5 @@
+{{ config(enabled=fivetran_utils.enabled_vars(['fivetran_log_credits_used'])) }}
+
 with table_mar as (
 
     select *
@@ -45,4 +47,4 @@ join_credits_mar as (
 )
 
 select * from join_credits_mar
-order by measured_month desc
+order by measured_month desc

models/fivetran_log__mar_table_history.sql

@@ -1,3 +1,5 @@
+{{ config(enabled=fivetran_utils.enabled_vars(['fivetran_log_active_volume'])) }}
+
 with active_volume as (
 
     select 
@@ -71,4 +73,4 @@ mar_join as (
 )
 
 select * from mar_join
-order by measured_month desc, destination_id, connector_name
+order by measured_month desc, destination_id, connector_name

models/staging/stg_fivetran_log__account_membership.sql

@@ -1,3 +1,5 @@
+{{ config(enabled=fivetran_utils.enabled_vars(['fivetran_log_account_membership'])) }}
+
 with account_membership as (
 
     select * from {{ var('account_membership') }}
@@ -17,4 +19,4 @@ fields as (
 
 )
 
-select * from fields
+select * from fields

models/staging/stg_fivetran_log__active_volume.sql

@@ -1,3 +1,5 @@
+{{ config(enabled=fivetran_utils.enabled_vars(['fivetran_log_active_volume'])) }}
+
 with active_volume as (
 
     select * from {{ var('active_volume') }}
@@ -18,4 +20,4 @@ fields as (
     from active_volume
 )
 
-select * from fields
+select * from fields

models/staging/stg_fivetran_log__credits_used.sql

@@ -1,3 +1,5 @@
+{{ config(enabled=fivetran_utils.enabled_vars(['fivetran_log_credits_used'])) }}
+
 with  credits_used as (
 
     select * from {{ var('credits_used') }}
@@ -14,4 +16,4 @@ fields as (
     from credits_used
 )
 
-select * from fields
+select * from fields

models/staging/stg_fivetran_log__destination_membership.sql

@@ -1,3 +1,5 @@
+{{ config(enabled=fivetran_utils.enabled_vars(['fivetran_log_destination_membership'])) }}
+
 with destination_membership as (
 
     select * from {{ var('destination_membership') }}
@@ -16,4 +18,4 @@ fields as (
     from destination_membership
 )
 
-select * from fields
+select * from fields

models/staging/stg_fivetran_log__user.sql

@@ -1,3 +1,5 @@
+{{ config(enabled=fivetran_utils.enabled_vars(['fivetran_log_user'])) }}
+
 with fivetran_user as (
 
     select * from {{ var('user') }}
@@ -20,4 +22,4 @@ fields as (
 
 )
 
-select * from fields
+select * from fields