From a6b633695003c8c441057823b9520d57cc6c9e4f Mon Sep 17 00:00:00 2001 From: Bishop Kammeraad Date: Wed, 21 Oct 2026 15:49:24 -0400 Subject: [PATCH] Partition retained earnings windows by source_relation --- models/intermediate/int_quickbooks__retained_earnings.sql | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/models/intermediate/int_quickbooks__retained_earnings.sql b/models/intermediate/int_quickbooks__retained_earnings.sql index 433928bb..9484afc4 100644 --- a/models/intermediate/int_quickbooks__retained_earnings.sql +++ b/models/intermediate/int_quickbooks__retained_earnings.sql @@ -45,8 +45,8 @@ retained_earnings_beginning as ( select *, - sum(coalesce(period_net_change, 0)) over (order by period_first_day, period_first_day {{ fivetran_utils.partition_by_source_relation(package_name='quickbooks') }} rows unbounded preceding) as period_ending_balance, - sum(coalesce(period_net_converted_change, 0)) over (order by period_first_day, period_first_day {{ fivetran_utils.partition_by_source_relation(package_name='quickbooks') }} rows unbounded preceding) as period_ending_converted_balance + sum(coalesce(period_net_change, 0)) over ({{ fivetran_utils.partition_by_source_relation(package_name='quickbooks', has_other_partitions='no') }} order by period_first_day, period_first_day rows unbounded preceding) as period_ending_balance, + sum(coalesce(period_net_converted_change, 0)) over ({{ fivetran_utils.partition_by_source_relation(package_name='quickbooks', has_other_partitions='no') }} order by period_first_day, period_first_day rows unbounded preceding) as period_ending_converted_balance from retained_earnings_starter ), @@ -69,10 +69,10 @@ final as ( period_first_day, period_last_day, period_net_change, - lag(coalesce(period_ending_balance,0)) over (order by period_first_day {{ fivetran_utils.partition_by_source_relation(package_name='quickbooks') }}) as period_beginning_balance, + lag(coalesce(period_ending_balance,0)) over ({{ fivetran_utils.partition_by_source_relation(package_name='quickbooks', has_other_partitions='no') }} order by period_first_day) as period_beginning_balance, period_ending_balance, period_net_converted_change, - lag(coalesce(period_ending_balance,0)) over (order by period_first_day {{ fivetran_utils.partition_by_source_relation(package_name='quickbooks') }}) as period_beginning_converted_balance, + lag(coalesce(period_ending_balance,0)) over ({{ fivetran_utils.partition_by_source_relation(package_name='quickbooks', has_other_partitions='no') }} order by period_first_day) as period_beginning_converted_balance, period_ending_converted_balance from retained_earnings_beginning )