quick fixes from comments

This commit is contained in:
Mike Stepanovic 2024-11-08 18:13:43 -07:00
parent 8fcefe42d1
commit bfe11acb1e
3 changed files with 12 additions and 5 deletions

View File

@ -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,

View File

@ -22,4 +22,14 @@ SELECT
inserted_timestamp,
modified_timestamp
FROM
{{ ref('silver_stats__core_metrics_hourly') }}
{{ ref('silver_stats__core_metrics_hourly') }}
{% if is_incremental() %}
WHERE
block_timestamp_hour >= (
SELECT
MAX(block_timestamp_hour)
FROM
{{ this }}
) - INTERVAL '1 hour'
{% endif %}

View File

@ -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',