adding subscription_id in invoice table for use in the main stripe pa…

CHANGELOG.md

@@ -1,3 +1,7 @@
+# dbt_stripe_source v0.7.1
+## 🎉 Documentation and Feature Updates
+- Addition of subscription Id in the invoice tables
+- updating the get_invoice_columns.sql with subscription_id field and adding subscription_id in stg_stripe__invoice.sql for above change
 # dbt_stripe_source v0.7.0
 ## 🎉 Documentation and Feature Updates
 - Updated README documentation updates for easier navigation and setup of the dbt package

dbt_project.yml

@@ -1,7 +1,7 @@
 config-version: 2
 
 name: 'stripe_source'
-version: '0.7.0'
+version: '0.7.1'
 
 require-dbt-version: [">=1.0.0", "<2.0.0"]
 
@@ -31,6 +31,7 @@ vars:
     subscription: "{{ source('stripe', 'subscription') }}"
     credit_note: "{{ source('stripe', 'credit_note') }}"
     credit_note_line_item: "{{ source('stripe', 'credit_note_line_item') }}"
+
 
     #Variables to enable or disable models if you do not have the respective table.
     using_invoices: true
@@ -39,7 +40,7 @@ vars:
     using_subscriptions: true
 
     # variable to exclude or include historical subscription data
-    stripe__subscription_history: false
+    stripe__subscription_history: true
 
     # variable to exclude or include test data (based on `livemode`)
     using_livemode: true

macros/get_invoice_columns.sql

@@ -41,6 +41,7 @@
     {"name": "status_transitions_marked_uncollectible_at", "datatype": dbt_utils.type_timestamp()},
     {"name": "status_transitions_paid_at", "datatype": dbt_utils.type_timestamp()},
     {"name": "status_transitions_voided_at", "datatype": dbt_utils.type_timestamp()},
+    {"name": "subscription_id", "datatype": dbt_utils.type_string()},
     {"name": "subscription_proration_date", "datatype": dbt_utils.type_int()},
     {"name": "subtotal", "datatype": dbt_utils.type_int()},
     {"name": "tax", "datatype": dbt_utils.type_int()},

models/stg_stripe__invoice.sql

@@ -50,8 +50,9 @@ final as (
         subtotal,
         tax,
         tax_percent,
-        total
-
+        total,
+        subscription_id
+
         {% if var('stripe__invoice_metadata',[]) %}
         , {{ fivetran_utils.pivot_json_extract(string = 'metadata', list_of_properties = var('stripe__invoice_metadata')) }}
         {% endif %}