diff --git a/models/staging/stripe/stg_stripe__payment_intents.sql b/models/staging/stripe/stg_stripe__payment_intents.sql
index 54591fc..05482c0 100644
--- a/models/staging/stripe/stg_stripe__payment_intents.sql
+++ b/models/staging/stripe/stg_stripe__payment_intents.sql
@@ -1,5 +1,7 @@
 with
-    raw_payment_intents as (select * from {{ source("stripe_uk", "payment_intents") }}),
+    raw_payment_intents as (
+        {{ generate_stripe_sources_unioned_select("payment_intents") }}
+    ),
     stg_seed__currencies as (select * from {{ ref("stg_seed__currencies") }}),
     stg_stripe__payment_intents as (
         select
@@ -64,6 +66,7 @@ with
             {{ adapter.quote("automatic_payment_methods") }},
             {{ adapter.quote("statement_descriptor_suffix") }},
             {{ adapter.quote("payment_method_configuration_details") }},
+            {{ adapter.quote("stripe_source_account") }},
             {{ adapter.quote("_airbyte_extracted_at") }} as dwh_extracted_at_utc,
             cast(
                 {{ adapter.quote("_airbyte_extracted_at") }} as date