diff --git a/models/gold/core/core__fact_transactions.sql b/models/gold/core/core__fact_transactions.sql index 1389546..f91a339 100644 --- a/models/gold/core/core__fact_transactions.sql +++ b/models/gold/core/core__fact_transactions.sql @@ -79,6 +79,7 @@ SELECT fee, 0 ) AS fee, + b.fee_payer, {{ dbt_utils.generate_surrogate_key(['a.tx_id']) }} AS fact_transactions_id, SYSDATE() AS inserted_timestamp, SYSDATE() AS modified_timestamp, diff --git a/models/gold/stats/stats__ez_core_metrics_hourly.sql b/models/gold/stats/stats__ez_core_metrics_hourly.sql index 4508dc4..42d042d 100644 --- a/models/gold/stats/stats__ez_core_metrics_hourly.sql +++ b/models/gold/stats/stats__ez_core_metrics_hourly.sql @@ -22,4 +22,14 @@ SELECT inserted_timestamp, modified_timestamp FROM - {{ ref('silver_stats__core_metrics_hourly') }} \ No newline at end of file + {{ ref('silver_stats__core_metrics_hourly') }} + +{% if is_incremental() %} +WHERE + block_timestamp_hour >= ( + SELECT + MAX(block_timestamp_hour) + FROM + {{ this }} + ) - INTERVAL '1 hour' +{% endif %} \ No newline at end of file diff --git a/models/silver/stats/silver_stats__core_metrics_hourly.sql b/models/silver/stats/silver_stats__core_metrics_hourly.sql index e2f3f4c..1cce217 100644 --- a/models/silver/stats/silver_stats__core_metrics_hourly.sql +++ b/models/silver/stats/silver_stats__core_metrics_hourly.sql @@ -55,12 +55,8 @@ SELECT SYSDATE() AS inserted_timestamp, SYSDATE() AS modified_timestamp, '{{ invocation_id }}' AS _invocation_id - FROM {{ ref('silver__transitions_fee') }} ts -JOIN - {{ref ('silver__native_transfers')}} tf - USING(tx_id) WHERE DATE_TRUNC('hour', ts.block_timestamp) < DATE_TRUNC( 'hour',